kubernetes/staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go

var pollPeriod …

var minimalNoChange …

var pollTimeout …

func TestConditionalProgressRequester(t *testing.T) { … }

func newTestConditionalProgressRequester(clock clock.WithTicker) *testConditionalProgressRequester { … }

type testConditionalProgressRequester …

func (pr *testConditionalProgressRequester) RequestWatchProgress(ctx context.Context) error { … }

func pollConditionNoChange(interval, stable, timeout time.Duration, condition func() bool) error { … }