package replicaset

import "k8s.io/kubernetes/test/e2e/framework/replicaset"

Index ¶

• func CheckNewRSAnnotations(c clientset.Interface, ns, deploymentName string, expectedAnnotations map[string]string) error
• func NewReplicaSet(name, namespace string, replicas int32, podLabels map[string]string, imageName, image string) *apps.ReplicaSet
• func RunReplicaSet(config testutils.ReplicaSetConfig) error
• func UpdateReplicaSetWithRetries(c clientset.Interface, namespace, name string, applyUpdate testutils.UpdateReplicaSetFunc) (*apps.ReplicaSet, error)
• func WaitForReadyReplicaSet(c clientset.Interface, ns, name string) error
• func WaitForReplicaSetDesiredReplicas(rsClient appsclient.ReplicaSetsGetter, replicaSet *apps.ReplicaSet) error
• func WaitForReplicaSetTargetAvailableReplicas(c clientset.Interface, replicaSet *apps.ReplicaSet, targetReplicaNum int32) error
• func WaitForReplicaSetTargetSpecReplicas(c clientset.Interface, replicaSet *apps.ReplicaSet, targetReplicaNum int32) error

Functions ¶

func CheckNewRSAnnotations ¶

func CheckNewRSAnnotations(c clientset.Interface, ns, deploymentName string, expectedAnnotations map[string]string) error

CheckNewRSAnnotations check if the new RS's annotation is as expected

func NewReplicaSet ¶

func NewReplicaSet(name, namespace string, replicas int32, podLabels map[string]string, imageName, image string) *apps.ReplicaSet

NewReplicaSet returns a new ReplicaSet.

func RunReplicaSet ¶

func RunReplicaSet(config testutils.ReplicaSetConfig) error

RunReplicaSet launches (and verifies correctness) of a replicaset.

func UpdateReplicaSetWithRetries ¶

func UpdateReplicaSetWithRetries(c clientset.Interface, namespace, name string, applyUpdate testutils.UpdateReplicaSetFunc) (*apps.ReplicaSet, error)

UpdateReplicaSetWithRetries updates replicaset template with retries.

func WaitForReadyReplicaSet ¶

func WaitForReadyReplicaSet(c clientset.Interface, ns, name string) error

WaitForReadyReplicaSet waits until the replicaset has all of its replicas ready.

func WaitForReplicaSetDesiredReplicas ¶

func WaitForReplicaSetDesiredReplicas(rsClient appsclient.ReplicaSetsGetter, replicaSet *apps.ReplicaSet) error

WaitForReplicaSetDesiredReplicas waits until the replicaset has desired number of replicas.

func WaitForReplicaSetTargetAvailableReplicas ¶

func WaitForReplicaSetTargetAvailableReplicas(c clientset.Interface, replicaSet *apps.ReplicaSet, targetReplicaNum int32) error

WaitForReplicaSetTargetAvailableReplicas waits for .status.availableReplicas of a RS to equal targetReplicaNum

func WaitForReplicaSetTargetSpecReplicas ¶

func WaitForReplicaSetTargetSpecReplicas(c clientset.Interface, replicaSet *apps.ReplicaSet, targetReplicaNum int32) error

WaitForReplicaSetTargetSpecReplicas waits for .spec.replicas of a RS to equal targetReplicaNum

Source Files ¶

fixtures.go rest.go wait.go