Versions in this module Expand all Collapse all v1 v1.2.2 Mar 30, 2023 Changes in this version + var ErrArgument = errors.New("incorrect task argument") + var ErrClosed = errors.New("TimingWheel is closed already") + type Execute func(key, value any) + type TimingWheel struct + func NewTimingWheel(interval time.Duration, numSlots int, execute Execute) (*TimingWheel, error) + func NewTimingWheelWithTicker(interval time.Duration, numSlots int, execute Execute, ticker timex.Ticker) (*TimingWheel, error) + func (tw *TimingWheel) Drain(fn func(key, value any)) error + func (tw *TimingWheel) MoveTimer(key any, delay time.Duration) error + func (tw *TimingWheel) RemoveTimer(key any) error + func (tw *TimingWheel) SetTimer(key, value any, delay time.Duration) error + func (tw *TimingWheel) Stop()