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) {}