source

Documentation

Index

• func NewDeploymentsController(lw cache.ListerWatcher, period time.Duration, ch chan<- DeploymentUpdate) cache.Controller
• func NewListWatchFromClient(c cache.Getter, resource string, namespace string, ...) *cache.ListWatch
• func NewRCController(lw cache.ListerWatcher, period time.Duration, ch chan<- RCUpdate) cache.Controller
• func NewSourceAPI(v1get cache.Getter, batev1 cache.Getter, period time.Duration, ...)
• func NewStatefulSetsController(lw cache.ListerWatcher, period time.Duration, ch chan<- StatefulSetUpdate) cache.Controller
• type DeploymentUpdate
• type Operation
• type RCUpdate
• type StatefulSetUpdate

Functions

func NewDeploymentsController

func NewDeploymentsController(lw cache.ListerWatcher, period time.Duration, ch chan<- DeploymentUpdate) cache.Controller

NewDeploymentsController creates a controller that is watching deployments and sending updates into deployments channel.

func NewListWatchFromClient

func NewListWatchFromClient(c cache.Getter, resource string, namespace string, fieldSelector fields.Selector) *cache.ListWatch

NewListWatchFromClient creates a new ListWatch from the specified client, resource, namespace and field selector.

func NewRCController

func NewRCController(lw cache.ListerWatcher, period time.Duration, ch chan<- RCUpdate) cache.Controller

NewRCController creates a controller that is watching rc and sending updates into ServiceUpdate channel.

func NewSourceAPI

func NewSourceAPI(v1get cache.Getter, batev1 cache.Getter, period time.Duration, rcsChan chan<- RCUpdate, deploymentsChan chan<- DeploymentUpdate, statefulChan chan<- StatefulSetUpdate, stopCh <-chan struct{})

NewSourceAPI creates config source that watches for changes to the services and pods.

func NewStatefulSetsController

func NewStatefulSetsController(lw cache.ListerWatcher, period time.Duration, ch chan<- StatefulSetUpdate) cache.Controller

NewStatefulSetsController creates a controller that is watching statefulset and sending updates into deployments channel.

Types

type DeploymentUpdate

type DeploymentUpdate struct {
	Deployment *v1beta1.Deployment
	Op         Operation
}

DeploymentUpdate describes an operation of deployment, sent on the channel. You can add, update or remove single endpoints by setting Op == ADD|UPDATE|REMOVE.

type Operation

type Operation int

Operation is a type of operation of services or endpoints.

const (
	ADD Operation = iota
	UPDATE
	REMOVE
	SYNCED
)

These are the available operation types.

type RCUpdate

type RCUpdate struct {
	RC *v1.ReplicationController
	Op Operation
}

RCUpdate describes an operation of endpoints, sent on the channel. You can add, update or remove single endpoints by setting Op == ADD|UPDATE|REMOVE.

type StatefulSetUpdate

type StatefulSetUpdate struct {
	StatefulSet *v1beta1.StatefulSet
	Op          Operation
}

StatefulSetUpdate describes an operation of endpoints, sent on the channel. You can add, update or remove single endpoints by setting Op == ADD|UPDATE|REMOVE.