kubernetes/test/integration/replicationcontroller/replicationcontroller_test.go

const interval …

const timeout …

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

func newRC(name, namespace string, replicas int) *v1.ReplicationController { … }

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

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

// Run RC controller and informers
func runControllerAndInformers(t *testing.T, rm *replication.ReplicationManager, informers informers.SharedInformerFactory, podNum int) func() { … }

// wait for the podInformer to observe the pods. Call this function before
// running the RC 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 createRCsPods(t *testing.T, clientSet clientset.Interface, rcs []*v1.ReplicationController, pods []*v1.Pod) ([]*v1.ReplicationController, []*v1.Pod) { … }

// Verify .Status.Replicas is equal to .Spec.Replicas
func waitRCStable(t *testing.T, clientSet clientset.Interface, rc *v1.ReplicationController) { … }

// Update .Spec.Replicas to replicas and verify .Status.Replicas is changed accordingly
func scaleRC(t *testing.T, c clientset.Interface, rc *v1.ReplicationController, 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, pod *v1.Pod, updateStatusFunc func(*v1.Pod)) { … }

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

func updateRC(t *testing.T, rcClient typedv1.ReplicationControllerInterface, rcName string, updateFunc func(*v1.ReplicationController)) *v1.ReplicationController { … }

// Verify ControllerRef of a RC pod that has incorrect attributes is automatically patched by the RC
func testPodControllerRefPatch(t *testing.T, c clientset.Interface, pod *v1.Pod, ownerReference *metav1.OwnerReference, rc *v1.ReplicationController, 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, rc *v1.ReplicationController, replicas int32) { … }

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

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

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

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

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

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

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

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

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

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

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