kubernetes/pkg/controller/statefulset/stateful_set_utils_test.go

type noopRecorder …

func (r *noopRecorder) Event(object runtime.Object, eventtype, reason, message string) { … }

func (r *noopRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{ … }

func (r *noopRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{ … }

// getClaimPodName gets the name of the Pod associated with the Claim, or an empty string if this doesn't look matching.
func getClaimPodName(set *apps.StatefulSet, claim *v1.PersistentVolumeClaim) string { … }

// ownerRefsChanged returns true if newRefs does not match originalRefs.
func ownerRefsChanged(originalRefs, newRefs []metav1.OwnerReference) bool { … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

func newPod() *v1.Pod { … }

func newPVC(name string) v1.PersistentVolumeClaim { … }

func newStatefulSetWithVolumes(replicas int32, name string, petMounts []v1.VolumeMount, podMounts []v1.VolumeMount) *apps.StatefulSet { … }

func newStatefulSet(replicas int32) *apps.StatefulSet { … }

func newStatefulSetWithLabels(replicas int32, name string, uid types.UID, labels map[string]string) *apps.StatefulSet { … }

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