kubernetes/staging/src/k8s.io/client-go/util/workqueue/default_rate_limiters_test.go

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

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

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

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

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

var _ …

func NewStepRateLimiter(baseDelay time.Duration, maxDelay time.Duration, threshold int) RateLimiter { … }

type StepRateLimiter …

func (r *StepRateLimiter) When(item interface{ … }

func (r *StepRateLimiter) NumRequeues(item interface{ … }

func (r *StepRateLimiter) Forget(item interface{ … }