util

type AlignedTicker ¶

type AlignedTicker struct {
	C <-chan time.Time
	// contains filtered or unexported fields
}

AlignedTicker is a wrapper around time.Ticker will align the time on a specific interval. The first tick will always occur within interval, the caller should explicitly discard this on creation, or not. Instead of firing at: [T+1*interval, T+2*interval, T+3*interval, ...]

It will fire at: r = roundup(T, interval)+offset [r+1*interval, r+interval*2, r+3*interval, ...]

The time.Time sent to the channel is guaranteed to be r+offset+n*interval, rather than the actual time of firing.

func NewAlignedTicker(interval, offset time.Duration) *AlignedTicker

func NewAlignedTickerWithContext(ctx context.Context, interval, offset time.Duration) *AlignedTicker

func (at *AlignedTicker) Stop()