kubernetes/test/e2e/apimachinery/etcd_failure.go

var _ …

func etcdFailTest(ctx context.Context, f *framework.Framework, failCommand, fixCommand string) { … }

const etcdFailureDuration …

func doEtcdFailure(ctx context.Context, f *framework.Framework, failCommand, fixCommand string) { … }

func masterExec(ctx context.Context, f *framework.Framework, cmd string) { … }

func checkExistingRCRecovers(ctx context.Context, f *framework.Framework) { … }