kubernetes/test/e2e/upgrades/apps/statefulset.go

// createStatefulSetService creates a Headless Service with Name name and Selector set to match labels.
func createStatefulSetService(name string, labels map[string]string) *v1.Service { … }

type StatefulSetUpgradeTest …

// Name returns the tracking name of the test.
func (StatefulSetUpgradeTest) Name() string { … }

// Skip returns true when this test can be skipped.
func (StatefulSetUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool { … }

// Setup creates a StatefulSet and a HeadlessService. It verifies the basic SatefulSet properties
func (t *StatefulSetUpgradeTest) Setup(ctx context.Context, f *framework.Framework) { … }

// Test waits for the upgrade to complete and verifies the StatefulSet basic functionality
func (t *StatefulSetUpgradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{ … }

// Teardown deletes all StatefulSets
func (t *StatefulSetUpgradeTest) Teardown(ctx context.Context, f *framework.Framework) { … }

func (t *StatefulSetUpgradeTest) verify(ctx context.Context, f *framework.Framework) { … }

func (t *StatefulSetUpgradeTest) restart(ctx context.Context, f *framework.Framework) { … }