controller

Apr 8, 2016

Changes in this version

+ var UIDSetKeyFunc = func(obj interface{}) (string, error)

+ func FilterActiveReplicaSets(replicaSets []*extensions.ReplicaSet) []*extensions.ReplicaSet

+ func IsPodActive(p api.Pod) bool

+ func PodKey(pod *api.Pod) string

+ type ControlleeExpectations struct

+ func (e *ControlleeExpectations) Add(add, del int64)

+ func (e *ControlleeExpectations) Fulfilled() bool

+ func (e *ControlleeExpectations) GetExpectations() (int64, int64)

type ControllerExpectations

+ func (r *ControllerExpectations) LowerExpectations(controllerKey string, add, del int)

+ func (r *ControllerExpectations) RaiseExpectations(controllerKey string, add, del int)

type ControllerExpectationsInterface

+ LowerExpectations func(controllerKey string, add, del int)

+ RaiseExpectations func(controllerKey string, add, del int)

+ type ControllersByCreationTimestamp []*api.ReplicationController

+ func (o ControllersByCreationTimestamp) Len() int

+ func (o ControllersByCreationTimestamp) Less(i, j int) bool

+ func (o ControllersByCreationTimestamp) Swap(i, j int)

+ type MatchingCache struct

+ func NewMatchingCache(maxCacheEntries int) *MatchingCache

+ func (c *MatchingCache) Add(labelObj objectWithMeta, selectorObj objectWithMeta)

+ func (c *MatchingCache) GetMatchingObject(labelObj objectWithMeta) (controller interface{}, exists bool)

+ func (c *MatchingCache) InvalidateAll()

+ func (c *MatchingCache) Update(labelObj objectWithMeta, selectorObj objectWithMeta)

+ type ReplicaSetsByCreationTimestamp []*extensions.ReplicaSet

+ func (o ReplicaSetsByCreationTimestamp) Len() int

+ func (o ReplicaSetsByCreationTimestamp) Less(i, j int) bool

+ func (o ReplicaSetsByCreationTimestamp) Swap(i, j int)

type ResyncPeriodFunc

+ func StaticResyncPeriodFunc(resyncPeriod time.Duration) ResyncPeriodFunc

+ type UIDSet struct

+ type UIDTrackingControllerExpectations struct

+ func NewUIDTrackingControllerExpectations(ce ControllerExpectationsInterface) *UIDTrackingControllerExpectations

+ func (u *UIDTrackingControllerExpectations) DeleteExpectations(rcKey string)

+ func (u *UIDTrackingControllerExpectations) DeletionObserved(rcKey, deleteKey string)

+ func (u *UIDTrackingControllerExpectations) ExpectDeletions(rcKey string, deletedKeys []string) error

+ func (u *UIDTrackingControllerExpectations) GetUIDs(controllerKey string) sets.String

Jan 8, 2016

Changes in this version

+ func NoResyncPeriodFunc() time.Duration

+ type ResyncPeriodFunc func() time.Duration

Sep 25, 2015

Changes in this version

+ var ExpKeyFunc = func(obj interface{}) (string, error)

+ var KeyFunc = framework.DeletionHandlingMetaNamespaceKeyFunc

+ type ActivePods []*api.Pod

+ func (s ActivePods) Len() int

+ func (s ActivePods) Less(i, j int) bool

+ func (s ActivePods) Swap(i, j int)

+ type ControllerExpectations struct

+ func NewControllerExpectations() *ControllerExpectations

+ func (r *ControllerExpectations) CreationObserved(controllerKey string)

+ func (r *ControllerExpectations) DeleteExpectations(controllerKey string)

+ func (r *ControllerExpectations) DeletionObserved(controllerKey string)

+ func (r *ControllerExpectations) ExpectCreations(controllerKey string, adds int) error

+ func (r *ControllerExpectations) ExpectDeletions(controllerKey string, dels int) error

+ func (r *ControllerExpectations) GetExpectations(controllerKey string) (*PodExpectations, bool, error)

+ func (r *ControllerExpectations) SatisfiedExpectations(controllerKey string) bool

+ func (r *ControllerExpectations) SetExpectations(controllerKey string, add, del int) error

+ type ControllerExpectationsInterface interface

+ CreationObserved func(controllerKey string)

+ DeleteExpectations func(controllerKey string)

+ DeletionObserved func(controllerKey string)

+ ExpectCreations func(controllerKey string, adds int) error

+ ExpectDeletions func(controllerKey string, dels int) error

+ GetExpectations func(controllerKey string) (*PodExpectations, bool, error)

+ SatisfiedExpectations func(controllerKey string) bool

+ SetExpectations func(controllerKey string, add, del int) error

+ type FakePodControl struct

+ DeletePodName []string

+ Err error

+ Templates []api.PodTemplateSpec

+ func (f *FakePodControl) Clear()

+ func (f *FakePodControl) CreatePods(namespace string, spec *api.PodTemplateSpec, object runtime.Object) error

+ func (f *FakePodControl) CreatePodsOnNode(nodeName, namespace string, template *api.PodTemplateSpec, ...) error

+ func (f *FakePodControl) DeletePod(namespace string, podName string) error

type PodControlInterface

+ CreatePods func(namespace string, template *api.PodTemplateSpec, object runtime.Object) error

+ CreatePodsOnNode func(nodeName, namespace string, template *api.PodTemplateSpec, ...) error

+ DeletePod func(namespace string, podID string) error

type PodExpectations

+ func (e *PodExpectations) GetExpectations() (int64, int64)

type RealPodControl

+ KubeClient client.Interface

+ Recorder record.EventRecorder

+ func (r RealPodControl) CreatePods(namespace string, template *api.PodTemplateSpec, object runtime.Object) error

+ func (r RealPodControl) CreatePodsOnNode(nodeName, namespace string, template *api.PodTemplateSpec, ...) error

+ func (r RealPodControl) DeletePod(namespace, podID string) error

Jul 16, 2015

Changes in this version

+ const PodStoreSyncedPollPeriod

Jun 22, 2015

Changes in this version

type RCExpectations

+ func (r *RCExpectations) DeleteExpectations(rcKey string)

+ type RCExpectationsManager interface

+ CreationObserved func(rc *api.ReplicationController)

+ DeleteExpectations func(rcKey string)

+ DeletionObserved func(rc *api.ReplicationController)

+ ExpectCreations func(rc *api.ReplicationController, adds int) error

+ ExpectDeletions func(rc *api.ReplicationController, dels int) error

+ GetExpectations func(rc *api.ReplicationController) (*PodExpectations, bool, error)

+ SatisfiedExpectations func(rc *api.ReplicationController) bool

type ReplicationManager

+ func (rm *ReplicationManager) SetEventRecorder(recorder record.EventRecorder)

May 12, 2015

Changes in this version

+ const BurstReplicas

+ const ExpectationsTimeout

+ const FullControllerResyncPeriod

+ const PodRelistPeriod

+ type Expectations interface

+ Fulfilled func() bool

+ type PodExpectations struct

+ func (e *PodExpectations) Fulfilled() bool

+ func (e *PodExpectations) Seen(add, del int64)

+ type RCExpectations struct

+ func NewRCExpectations() *RCExpectations

+ func (r *RCExpectations) CreationObserved(rc *api.ReplicationController)

+ func (r *RCExpectations) DeletionObserved(rc *api.ReplicationController)

+ func (r *RCExpectations) ExpectCreations(rc *api.ReplicationController, adds int) error

+ func (r *RCExpectations) ExpectDeletions(rc *api.ReplicationController, dels int) error

+ func (r *RCExpectations) GetExpectations(rc *api.ReplicationController) (*PodExpectations, bool, error)

+ func (r *RCExpectations) SatisfiedExpectations(rc *api.ReplicationController) bool

Apr 29, 2015

Changes in this version

+ const CreatedByAnnotation

Mar 16, 2015

Changes in this version

+ const DefaultSyncPeriod

Dec 23, 2014

Changes in this version

+ func FilterActivePods(pods []api.Pod) []api.Pod

Oct 17, 2014

Changes in this version

+ type PodControlInterface interface

+ type RealPodControl struct

+ type ReplicationManager struct

+ func NewReplicationManager(kubeClient client.Interface) *ReplicationManager

+ func (rm *ReplicationManager) Run(period time.Duration)