track

Documentation

Index

• type Delayer
• type ExpBackoff
  • func NewExpBackoff(base int) *ExpBackoff
  • func (e *ExpBackoff) Delay() time.Duration
• type TimeTracker
  • func NewTracker(delayer Delayer) *TimeTracker
  • func (t *TimeTracker) HasBeenRan() bool
  • func (t *TimeTracker) IsReady() bool
  • func (t *TimeTracker) SetNext() (time.Duration, time.Time)

Types

type Delayer

type Delayer interface {
	Delay() time.Duration
}

Delayer is used to delay some action

type ExpBackoff

type ExpBackoff struct {
	// contains filtered or unexported fields
}

ExpBackoff is used as delayer, implements exponential backoff algorithm

func NewExpBackoff

func NewExpBackoff(base int) *ExpBackoff

NewExpBackoff returns pointer to new ExpBackoff base is meant to be seconds

func (*ExpBackoff) Delay

func (e *ExpBackoff) Delay() time.Duration

Delay returns seconds

type TimeTracker

type TimeTracker struct {
	// contains filtered or unexported fields
}

TimeTracker is used to keep track of something

func NewTracker

func NewTracker(delayer Delayer) *TimeTracker

NewTracker returns pointer to new TimeTracker and sets its Delayer

func (*TimeTracker) HasBeenRan

func (t *TimeTracker) HasBeenRan() bool

HasBeenRan checks how many times has time delayer and returns true if ever ran

func (*TimeTracker) IsReady

func (t *TimeTracker) IsReady() bool

IsReady checks if current time is after nextTime On first check before calling SetNext, always true due to nextTime having zero value

func (*TimeTracker) SetNext

func (t *TimeTracker) SetNext() (time.Duration, time.Time)

SetNext updates nextTime based on delayer implementation Returns delay and time at which will current time be after it