kubernetes/staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go

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

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

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

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

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

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

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

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

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

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

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

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

type fakePoller …

func fakeTicker(max int, used *int32, doneFunc func()) waitFunc { … }

func (fp *fakePoller) GetwaitFunc() waitFunc { … }

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

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

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

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

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

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

// Test_waitForWithEarlyClosing_waitFunc tests WaitFor when the waitFunc closes its channel. The WaitFor should
// always return ErrWaitTimeout.
func Test_waitForWithEarlyClosing_waitFunc(t *testing.T) { … }

// Test_waitForWithClosedChannel tests waitFor when it receives a closed channel. The waitFor should
// always return ErrWaitTimeout.
func Test_waitForWithClosedChannel(t *testing.T) { … }

// Test_waitForWithContextCancelsContext verifies that after the condition func returns true,
// waitForWithContext cancels the context it supplies to the WaitWithContextFunc.
func Test_waitForWithContextCancelsContext(t *testing.T) { … }

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

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

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

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

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

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

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

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

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

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

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

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

func defaultContext() (context.Context, context.CancelFunc) { … }

func cancelledContext() (context.Context, context.CancelFunc) { … }

func deadlinedContext() (context.Context, context.CancelFunc) { … }

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

func BenchmarkExponentialBackoffWithContext(b *testing.B) { … }

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

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

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

func Benchmark_poll(b *testing.B) { … }