kubernetes/test/integration/replicaset/replicaset_test.go

const interval …

const timeout …

func labelMap() map[string]string { … }

func newRS(name, namespace string, replicas int) *apps.ReplicaSet { … }

func newMatchingPod(podName, namespace string) *v1.Pod { … }

func rmSetup(t *testing.T) (context.Context, kubeapiservertesting.TearDownFunc, *replicaset.ReplicaSetController, informers.SharedInformerFactory, clientset.Interface) { … }

func rmSimpleSetup(t *testing.T) (kubeapiservertesting.TearDownFunc, clientset.Interface) { … }

// Run RS controller and informers
func runControllerAndInformers(t *testing.T, rm *replicaset.ReplicaSetController, informers informers.SharedInformerFactory, podNum int) func() { … }

// wait for the podInformer to observe the pods. Call this function before
// running the RS controller to prevent the rc manager from creating new pods
// rather than adopting the existing ones.
func waitToObservePods(t *testing.T, podInformer cache.SharedIndexInformer, podNum int) { … }

func createRSsPods(t *testing.T, clientSet clientset.Interface, rss []*apps.ReplicaSet, pods []*v1.Pod) ([]*apps.ReplicaSet, []*v1.Pod) { … }

// Verify .Status.Replicas is equal to .Spec.Replicas
func waitRSStable(t *testing.T, clientSet clientset.Interface, rs *apps.ReplicaSet) { … }

// Update .Spec.Replicas to replicas and verify .Status.Replicas is changed accordingly
func scaleRS(t *testing.T, c clientset.Interface, rs *apps.ReplicaSet, replicas int32) { … }

func updatePod(t *testing.T, podClient typedv1.PodInterface, podName string, updateFunc func(*v1.Pod)) *v1.Pod { … }

func updatePodStatus(t *testing.T, podClient typedv1.PodInterface, podName string, updateStatusFunc func(*v1.Pod)) { … }

func getPods(t *testing.T, podClient typedv1.PodInterface, labelMap map[string]string) *v1.PodList { … }

func updateRS(t *testing.T, rsClient appsclient.ReplicaSetInterface, rsName string, updateFunc func(*apps.ReplicaSet)) *apps.ReplicaSet { … }

// Verify ControllerRef of a RS pod that has incorrect attributes is automatically patched by the RS
func testPodControllerRefPatch(t *testing.T, c clientset.Interface, pod *v1.Pod, ownerReference *metav1.OwnerReference, rs *apps.ReplicaSet, expectedOwnerReferenceNum int) { … }

func setPodsReadyCondition(t *testing.T, clientSet clientset.Interface, pods *v1.PodList, conditionStatus v1.ConditionStatus, lastTransitionTime time.Time) { … }

func testScalingUsingScaleSubresource(t *testing.T, c clientset.Interface, rs *apps.ReplicaSet, replicas int32) { … }

func TestAdoption(t *testing.T) { … }

// selectors are IMMUTABLE for all API versions except extensions/v1beta1
func TestRSSelectorImmutability(t *testing.T) { … }

func TestSpecReplicasChange(t *testing.T) { … }

func TestDeletingAndFailedPods(t *testing.T) { … }

func TestPodDeletionCost(t *testing.T) { … }

func TestOverlappingRSs(t *testing.T) { … }

func TestPodOrphaningAndAdoptionWhenLabelsChange(t *testing.T) { … }

func TestGeneralPodAdoption(t *testing.T) { … }

func TestReadyAndAvailableReplicas(t *testing.T) { … }

func TestRSScaleSubresource(t *testing.T) { … }

func TestExtraPodsAdoptionAndDeletion(t *testing.T) { … }

func TestFullyLabeledReplicas(t *testing.T) { … }

func TestReplicaSetsAppsV1DefaultGCPolicy(t *testing.T) { … }