Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const ExpectationsTimeout + const FailedCreatePodReason + const FailedDeletePodReason + const SlowStartInitialBatchSize + const SuccessfulCreatePodReason + const SuccessfulDeletePodReason + var ExpKeyFunc = func(obj interface{}) (string, error) + var KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc + var UIDSetKeyFunc = func(obj interface{}) (string, error) + var UpdateLabelBackoff = wait.Backoff + var UpdateTaintBackoff = wait.Backoff + func AddOrUpdateLabelsOnNode(kubeClient clientset.Interface, nodeName string, ...) error + func AddOrUpdateTaintOnNode(c clientset.Interface, nodeName string, taints ...*v1.Taint) error + func ComputeHash(template *v1.PodTemplateSpec, collisionCount *int32) string + func FilterActivePods(pods []*v1.Pod) []*v1.Pod + func FilterActiveReplicaSets(replicaSets []*apps.ReplicaSet) []*apps.ReplicaSet + func FilterReplicaSets(RSes []*apps.ReplicaSet, filterFn filterRS) []*apps.ReplicaSet + func GetPodFromTemplate(template *v1.PodTemplateSpec, parentObject runtime.Object, ...) (*v1.Pod, error) + func IsPodActive(p *v1.Pod) bool + func NoResyncPeriodFunc() time.Duration + func PatchNodeTaints(c clientset.Interface, nodeName string, oldNode *v1.Node, newNode *v1.Node) error + func PodKey(pod *v1.Pod) string + func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() error + func RemoveTaintOffNode(c clientset.Interface, nodeName string, node *v1.Node, taints ...*v1.Taint) error + type ActivePods []*v1.Pod + func (s ActivePods) Len() int + func (s ActivePods) Less(i, j int) bool + func (s ActivePods) Swap(i, j int) + type ActivePodsWithRanks struct + Pods []*v1.Pod + Rank []int + func (s ActivePodsWithRanks) Len() int + func (s ActivePodsWithRanks) Less(i, j int) bool + func (s ActivePodsWithRanks) Swap(i, j int) + type BaseControllerRefManager struct + CanAdoptFunc func() error + Controller metav1.Object + Selector labels.Selector + func (m *BaseControllerRefManager) CanAdopt() error + func (m *BaseControllerRefManager) ClaimObject(obj metav1.Object, match func(metav1.Object) bool, ...) (bool, error) + type ByLogging []*v1.Pod + func (s ByLogging) Len() int + func (s ByLogging) Less(i, j int) bool + func (s ByLogging) Swap(i, j int) + type ControlleeExpectations struct + func (e *ControlleeExpectations) Add(add, del int64) + func (e *ControlleeExpectations) Fulfilled() bool + func (e *ControlleeExpectations) GetExpectations() (int64, int64) + type ControllerClientBuilder interface + Client func(name string) (clientset.Interface, error) + ClientOrDie func(name string) clientset.Interface + Config func(name string) (*restclient.Config, error) + ConfigOrDie func(name string) *restclient.Config + func NewDynamicClientBuilder(clientConfig *restclient.Config, coreClient v1core.CoreV1Interface, ns string) ControllerClientBuilder + func NewTestDynamicClientBuilder(clientConfig *restclient.Config, coreClient v1core.CoreV1Interface, ns string, ...) ControllerClientBuilder + 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) (*ControlleeExpectations, bool, error) + func (r *ControllerExpectations) LowerExpectations(controllerKey string, add, del int) + func (r *ControllerExpectations) RaiseExpectations(controllerKey string, add, del int) + 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) (*ControlleeExpectations, bool, error) + LowerExpectations func(controllerKey string, add, del int) + RaiseExpectations func(controllerKey string, add, del int) + SatisfiedExpectations func(controllerKey string) bool + SetExpectations func(controllerKey string, add, del int) error + type ControllerRevisionControlInterface interface + PatchControllerRevision func(namespace, name string, data []byte) error + type ControllerRevisionControllerRefManager struct + func NewControllerRevisionControllerRefManager(crControl ControllerRevisionControlInterface, controller metav1.Object, ...) *ControllerRevisionControllerRefManager + func (m *ControllerRevisionControllerRefManager) AdoptControllerRevision(history *apps.ControllerRevision) error + func (m *ControllerRevisionControllerRefManager) ClaimControllerRevisions(histories []*apps.ControllerRevision) ([]*apps.ControllerRevision, error) + func (m *ControllerRevisionControllerRefManager) ReleaseControllerRevision(history *apps.ControllerRevision) error + type ControllersByCreationTimestamp []*v1.ReplicationController + func (o ControllersByCreationTimestamp) Len() int + func (o ControllersByCreationTimestamp) Less(i, j int) bool + func (o ControllersByCreationTimestamp) Swap(i, j int) + type DynamicControllerClientBuilder struct + ClientConfig *restclient.Config + CoreClient v1core.CoreV1Interface + Namespace string + func (t *DynamicControllerClientBuilder) Client(name string) (clientset.Interface, error) + func (t *DynamicControllerClientBuilder) ClientOrDie(name string) clientset.Interface + func (t *DynamicControllerClientBuilder) Config(saName string) (*restclient.Config, error) + func (t *DynamicControllerClientBuilder) ConfigOrDie(name string) *restclient.Config + type Expectations interface + Fulfilled func() bool + type FakePodControl struct + ControllerRefs []metav1.OwnerReference + CreateCallCount int + CreateLimit int + DeletePodName []string + Err error + Patches [][]byte + Templates []v1.PodTemplateSpec + func (f *FakePodControl) Clear() + func (f *FakePodControl) CreatePods(namespace string, spec *v1.PodTemplateSpec, object runtime.Object) error + func (f *FakePodControl) CreatePodsOnNode(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error + func (f *FakePodControl) CreatePodsWithControllerRef(namespace string, spec *v1.PodTemplateSpec, object runtime.Object, ...) error + func (f *FakePodControl) DeletePod(namespace string, podID string, object runtime.Object) error + func (f *FakePodControl) PatchPod(namespace, name string, data []byte) error + type InformerFactory interface + ForResource func(resource schema.GroupVersionResource) (informers.GenericInformer, error) + Start func(stopCh <-chan struct{}) + func NewInformerFactory(typedInformerFactory informers.SharedInformerFactory, ...) InformerFactory + 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 PodControlInterface interface + CreatePods func(namespace string, template *v1.PodTemplateSpec, object runtime.Object) error + CreatePodsOnNode func(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error + CreatePodsWithControllerRef func(namespace string, template *v1.PodTemplateSpec, object runtime.Object, ...) error + DeletePod func(namespace string, podID string, object runtime.Object) error + PatchPod func(namespace, name string, data []byte) error + type PodControllerRefManager struct + func NewPodControllerRefManager(podControl PodControlInterface, controller metav1.Object, ...) *PodControllerRefManager + func (m *PodControllerRefManager) AdoptPod(pod *v1.Pod) error + func (m *PodControllerRefManager) ClaimPods(pods []*v1.Pod, filters ...func(*v1.Pod) bool) ([]*v1.Pod, error) + func (m *PodControllerRefManager) ReleasePod(pod *v1.Pod) error + type RSControlInterface interface + PatchReplicaSet func(namespace, name string, data []byte) error + type RealControllerRevisionControl struct + KubeClient clientset.Interface + func (r RealControllerRevisionControl) PatchControllerRevision(namespace, name string, data []byte) error + type RealPodControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (r RealPodControl) CreatePods(namespace string, template *v1.PodTemplateSpec, object runtime.Object) error + func (r RealPodControl) CreatePodsOnNode(nodeName, namespace string, template *v1.PodTemplateSpec, ...) error + func (r RealPodControl) CreatePodsWithControllerRef(namespace string, template *v1.PodTemplateSpec, ...) error + func (r RealPodControl) DeletePod(namespace string, podID string, object runtime.Object) error + func (r RealPodControl) PatchPod(namespace, name string, data []byte) error + type RealRSControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (r RealRSControl) PatchReplicaSet(namespace, name string, data []byte) error + type ReplicaSetControllerRefManager struct + func NewReplicaSetControllerRefManager(rsControl RSControlInterface, controller metav1.Object, ...) *ReplicaSetControllerRefManager + func (m *ReplicaSetControllerRefManager) AdoptReplicaSet(rs *apps.ReplicaSet) error + func (m *ReplicaSetControllerRefManager) ClaimReplicaSets(sets []*apps.ReplicaSet) ([]*apps.ReplicaSet, error) + func (m *ReplicaSetControllerRefManager) ReleaseReplicaSet(replicaSet *apps.ReplicaSet) error + type ReplicaSetsByCreationTimestamp []*apps.ReplicaSet + func (o ReplicaSetsByCreationTimestamp) Len() int + func (o ReplicaSetsByCreationTimestamp) Less(i, j int) bool + func (o ReplicaSetsByCreationTimestamp) Swap(i, j int) + type ReplicaSetsBySizeNewer []*apps.ReplicaSet + func (o ReplicaSetsBySizeNewer) Len() int + func (o ReplicaSetsBySizeNewer) Less(i, j int) bool + func (o ReplicaSetsBySizeNewer) Swap(i, j int) + type ReplicaSetsBySizeOlder []*apps.ReplicaSet + func (o ReplicaSetsBySizeOlder) Len() int + func (o ReplicaSetsBySizeOlder) Less(i, j int) bool + func (o ReplicaSetsBySizeOlder) Swap(i, j int) + type ResyncPeriodFunc func() time.Duration + func StaticResyncPeriodFunc(resyncPeriod time.Duration) ResyncPeriodFunc + type SAControllerClientBuilder struct + AuthenticationClient v1authentication.AuthenticationV1Interface + ClientConfig *restclient.Config + CoreClient v1core.CoreV1Interface + Namespace string + func (b SAControllerClientBuilder) Client(name string) (clientset.Interface, error) + func (b SAControllerClientBuilder) ClientOrDie(name string) clientset.Interface + func (b SAControllerClientBuilder) Config(name string) (*restclient.Config, error) + func (b SAControllerClientBuilder) ConfigOrDie(name string) *restclient.Config + type SimpleControllerClientBuilder struct + ClientConfig *restclient.Config + func (b SimpleControllerClientBuilder) Client(name string) (clientset.Interface, error) + func (b SimpleControllerClientBuilder) ClientOrDie(name string) clientset.Interface + func (b SimpleControllerClientBuilder) Config(name string) (*restclient.Config, error) + func (b SimpleControllerClientBuilder) ConfigOrDie(name string) *restclient.Config + 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