kubernetes/staging/src/k8s.io/client-go/util/flowcontrol/backoff.go

type backoffEntry …

type Backoff …

func NewFakeBackOff(initial, max time.Duration, tc *testingclock.FakeClock) *Backoff { … }

func NewBackOff(initial, max time.Duration) *Backoff { … }

func NewFakeBackOffWithJitter(initial, max time.Duration, tc *testingclock.FakeClock, maxJitterFactor float64) *Backoff { … }

func NewBackOffWithJitter(initial, max time.Duration, maxJitterFactor float64) *Backoff { … }

func newBackoff(clock clock.Clock, initial, max time.Duration, maxJitterFactor float64) *Backoff { … }

// Get the current backoff Duration
func (p *Backoff) Get(id string) time.Duration { … }

// move backoff to the next mark, capping at maxDuration
func (p *Backoff) Next(id string, eventTime time.Time) { … }

// Reset forces clearing of all backoff data for a given key.
func (p *Backoff) Reset(id string) { … }

// Returns True if the elapsed time since eventTime is smaller than the current backoff window
func (p *Backoff) IsInBackOffSince(id string, eventTime time.Time) bool { … }

// Returns True if time since lastupdate is less than the current backoff window.
func (p *Backoff) IsInBackOffSinceUpdate(id string, eventTime time.Time) bool { … }

// Garbage collect records that have aged past maxDuration. Backoff users are expected
// to invoke this periodically.
func (p *Backoff) GC() { … }

func (p *Backoff) DeleteEntry(id string) { … }

// Take a lock on *Backoff, before calling initEntryUnsafe
func (p *Backoff) initEntryUnsafe(id string) *backoffEntry { … }

func (p *Backoff) jitter(delay time.Duration) time.Duration { … }

// After 2*maxDuration we restart the backoff factor to the beginning
func hasExpired(eventTime time.Time, lastUpdate time.Time, maxDuration time.Duration) bool { … }