package podsource

import "k8s.io/kubernetes/contrib/mesos/pkg/executor/service/podsource"

Index

Constants 

const (
	// if we don't use this source then the kubelet will do funny, mirror things. we alias
	// this here for convenience. see the docs for Source for additional explanation.
	// @see ConfigSourceAnnotationKey
	MesosSource = kubetypes.ApiserverSource
)

Functions

func Mesos 

func Mesos(
	stop <-chan struct{},
	out chan<- interface{},
	podWatch *cache.ListWatch,
	registry executor.Registry,
	options ...Option,
)

Mesos spawns a new pod source that watches API server for changes and collaborates with executor.Registry to generate api.Pod objects in a fashion that's very Mesos-aware.

Types

type Filter 

type Filter interface {
	// Before is invoked before any pods are evaluated
	Before(podCount int)
	// Accept returns true if this pod should be accepted by the source; a value
	// of false results in the pod appearing to have been removed from apiserver.
	// If true, the caller should use the output pod value for the remainder of
	// the processing task. If false then the output pod value may be nil.
	Accept(*api.Pod) (*api.Pod, bool)
	// After is invoked after all pods have been evaluated
	After()
}

Filter is invoked for each snapshot of pod state that passes through this source

type FilterFunc 

type FilterFunc func(*api.Pod) (*api.Pod, bool)

FilterFunc is a simplified Filter implementation that only implements Filter.Accept, its Before and After implementations are noop.

func (FilterFunc) Accept 

func (f FilterFunc) Accept(pod *api.Pod) (*api.Pod, bool)

func (FilterFunc) After 

func (f FilterFunc) After()

func (FilterFunc) Before 

func (f FilterFunc) Before(_ int)

type Option 

type Option func(*Source)

func ContainerEnvOverlay 

func ContainerEnvOverlay(env []api.EnvVar) Option

type Source 

type Source struct {
	// contains filtered or unexported fields
}

Source Files

podsource.go

Version
v1.4.1-beta.0
Published
Sep 26, 2016
Platform
js/wasm
Imports
6 packages
Last checked
1 minute ago –

Tools for package owners.