kubernetes/pkg/util/async/bounded_frequency_runner_test.go

type receiver …

func (r *receiver) F() { … }

func (r *receiver) reset() bool { … }

func (r *receiver) setRetryFn(retryFn func()) { … }

type timerUpdate …

type fakeTimer …

func newFakeTimer() *fakeTimer { … }

func (ft *fakeTimer) C() <-chan time.Time { … }

func (ft *fakeTimer) Reset(in time.Duration) bool { … }

func (ft *fakeTimer) Stop() bool { … }

func (ft *fakeTimer) Now() time.Time { … }

func (ft *fakeTimer) Remaining() time.Duration { … }

func (ft *fakeTimer) Since(t time.Time) time.Duration { … }

func (ft *fakeTimer) Sleep(d time.Duration) { … }

// advance the current time.
func (ft *fakeTimer) advance(d time.Duration) { … }

// return the calling line number (for printing)
// test the timer's state
func checkTimer(name string, t *testing.T, upd timerUpdate, active bool, next time.Duration) { … }

// test and reset the receiver's state
func checkReceiver(name string, t *testing.T, receiver *receiver, expected bool) { … }

var minInterval …

var maxInterval …

func waitForReset(name string, t *testing.T, timer *fakeTimer, obj *receiver, expectCall bool, expectNext time.Duration) { … }

func waitForRun(name string, t *testing.T, timer *fakeTimer, obj *receiver) { … }

func waitForRunWithRetry(name string, t *testing.T, timer *fakeTimer, obj *receiver, expectNext time.Duration) { … }

func waitForDefer(name string, t *testing.T, timer *fakeTimer, obj *receiver, expectNext time.Duration) { … }

func waitForNothing(name string, t *testing.T, timer *fakeTimer, obj *receiver) { … }

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

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

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