source

package
v3.6.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 19, 2018 License: LGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL