clock

type Option ¶ added in v1.38.0

type Option func(*config)

func WithAlignment(start time.Time) Option

func WithClock(clk clock.Clock) Option

func WithStartupNotification(notifier chan bool) Option

type Ticker ¶

type Ticker struct {
	C chan time.Time
	// contains filtered or unexported fields
}

func NewTicker(interval, jitter, offset time.Duration, opt ...Option) *Ticker

func (t *Ticker) Stop()

type Timer ¶

type Timer struct {
	C chan time.Time
	// 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, opt ...Option) *Timer

func (t *Timer) Stop()