clock

type Ticker ¶

type Ticker interface {
	Elapsed() <-chan time.Time
	Stop()
}

func NewTicker(start time.Time, interval, jitter, offset time.Duration, align bool) Ticker

type Timer ¶

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

Timer delivers ticks at regular but unaligned intervals.

Because the next interval is scheduled based on the interval + jitter, you are guaranteed at least interval seconds without missing a tick and ticks will be evenly scheduled over time.

On average you will have one collection each interval + (jitter/2).

The first tick is emitted after interval+jitter seconds.

Ticks are dropped for slow consumers.

func NewTimer(interval, jitter time.Duration) *Timer

func (t *Timer) Elapsed() <-chan time.Time

func (t *Timer) Stop()