FixedMapper maps k8s host ports to offered ports ignoring hostPorts == 0 (remaining pod-private).

TODO(jdef) we use a Locker to guard against concurrent task state changes, but it would bereally, really nice to avoid doing this.

makePodKey constructs etcd paths to pod items enforcing namespace rules.

NewDefaultProcurement returns the default procurement strategy that combines validation and responsible Mesos resource procurement.

NewExecutorResourceProcurer returns a Procurement procuring executor resources If a given offer has no executor IDs set, the given prototype executor resources are considered for procurement.

NewHostPortMapper returns a new mapper based based on the port mapping key value.

NewNodeProcurement returns a Procurement that checks whether the given pod task and offer have valid node informations available and wehther the pod spec node selector matches the pod labels.

NewPodResourcesProcurement converts k8s pod cpu and memory resource requirements into mesos resource allocations.

NewPortsProcurement returns a Procurement procuring ports.

NewProcureState returns an ProcureState containing an empty Spec and a deep copy of the given offer.

reconstruct a task from metadata stashed in a pod entry.

WildcardMapper maps k8s wildcard ports (hostPort == 0) to any available offer port.

maps a Container.HostPort to the same exact offered host port, ignores .HostPort = 0.

same as HostPortMappingFixed, except that .HostPort of 0 are mapped to any port offered.

TODO(jdef) move this somewhere else.

A HostPortMapping represents the mapping between k8s container ports ports offered by mesos.

ProcureState holds the current state of the procurement pipeline.

A struct that describes a pod task.

Objects implementing the HostPortMapper interface generate port mappings from k8s container ports to ports offered by mesos.

Procurement is the interface that implements resource procurement.

state store for pod tasks.

AllOrNothingProcurement provides a convenient wrapper around multiple Procurement objectives: the failure of any Procurement in the set results in Procure failing.

HostPortMapperFunc is a function adapter to the HostPortMapper interface.

The ProcurementFunc type is an adapter to use ordinary functions as Procurement implementations.