Function NewSlottedTicker

pkg/util/time.go:168–205

(sf SlotInfoFunc, d time.Duration, slotJitter float64)

}

func NewSlottedTicker(sf SlotInfoFunc, d time.Duration, slotJitter float64) *SlottedTicker {
	c := make(chan time.Time, 1)
	ctx, cancel := context.WithCancel(context.Background())
	st := &SlottedTicker{
		C:           c,
		done:        cancel,
		d:           d,
		sf:          sf,
		shouldReset: true,
		slotJitter:  slotJitter,
	}
	slitIndex, totalSlots := sf()
	st.ticker = time.NewTicker(st.nextInterval())
	go func() {
		for ctx.Err() == nil {
			select {
			case t := <-st.ticker.C:
				if i, s := sf(); i != slitIndex || s != totalSlots {
					slitIndex, totalSlots = i, s
					st.ticker.Reset(st.nextInterval())
					st.shouldReset = true
					continue
				}

				c <- t
				if st.shouldReset {
					st.ticker.Reset(st.d)
				}

				st.shouldReset = false
			case <-ctx.Done():
				return
			}
		}
		close(c)
	}()
	return st
}

func (t *SlottedTicker) Stop() {
	t.ticker.Stop()