kubernetes/test/e2e_node/criproxy_test.go

var _ …

func getFailedToPullImageMsg(ctx context.Context, f *framework.Framework, podName string) (string, error) { … }

func getPodImagePullDuration(ctx context.Context, f *framework.Framework, podName string) (time.Duration, error) { … }

func newPullImageAlwaysPod() *v1.Pod { … }