kubernetes/test/e2e/node/pods.go

var _ …

func createAndTestPodRepeatedly(ctx context.Context, workers, iterations int, scenario podScenario, podClient v1core.PodInterface) { … }

type podScenario …

type podScenarioVerifier …

type podFastDeleteScenario …

func (s podFastDeleteScenario) Verifier(pod *v1.Pod) podScenarioVerifier { … }

func (s podFastDeleteScenario) IsLastEvent(event watch.Event) bool { … }

func (s podFastDeleteScenario) Action(ctx context.Context, pod *v1.Pod) (podScenarioVerifier, string, error) { … }

func (s podFastDeleteScenario) Pod(worker, attempt int) *v1.Pod { … }

type podStartVerifier …

var reBug88766 …

// Verify takes successive watch events for a given pod and returns an error if the status is unexpected.
// This verifier works for any pod which has 0 init containers and 1 regular container.
func (v *podStartVerifier) Verify(event watch.Event) error { … }

func (v *podStartVerifier) VerifyFinal(scenario string, total time.Duration) (*v1.Pod, []error) { … }