kubernetes/pkg/controller/statefulset/stateful_pod_control_test.go

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

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

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

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

type fakeIndexer …

func (f *fakeIndexer) GetByKey(key string) (interface{ … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func collectEvents(source <-chan string) []string { … }