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

const manifestPath …

type EtcdUpgradeTest …

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

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

func kubectlCreate(ns, file string) { … }

// Setup creates etcd statefulset and then verifies that the etcd is writable.
func (t *EtcdUpgradeTest) Setup(ctx context.Context, f *framework.Framework) { … }

func (t *EtcdUpgradeTest) listUsers() ([]string, error) { … }

func (t *EtcdUpgradeTest) addUser(name string) error { … }

func (t *EtcdUpgradeTest) getServiceIP(ctx context.Context, f *framework.Framework, ns, svcName string) string { … }

// Test waits for upgrade to complete and verifies if etcd is writable.
func (t *EtcdUpgradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{ … }

// Teardown does one final check of the data's availability.
func (t *EtcdUpgradeTest) Teardown(ctx context.Context, f *framework.Framework) { … }