timer

Apr 29, 2025

Changes in this version

+ type DerefTask interface

+ DerefTask func() *Task

Apr 17, 2025

Changes in this version

+ func AddDerefTask(task TaskContainer) error

type Task

+ func (t *Task) DerefTask() *Task

+ type TaskContainer interface

+ DerefTask func() *Task

type Timer

+ func (t *Timer) AddDerefTask(tc TaskContainer) error

Jan 2, 2025

Changes in this version

type Task

+ func (t *Task) Expiry() int64

+ func (t *Task) ExpiryAt() time.Time

Dec 31, 2024

Changes in this version

+ func AddTask(task *Task) error

+ func Go(f func())

+ func Start()

+ func Started() bool

+ func Stop()

+ func TaskCounter() int64

+ func TickMs() int64

+ func WheelSize() int

+ type Result int

+ const Result_AlreadyExpired

+ const Result_Canceled

+ const Result_Success

type Task

+ func AfterFunc(d time.Duration, f func()) (*Task, error)

type Timer

+ func DefaultTimer() *Timer

Aug 13, 2024

Changes in this version

type Task

+ func (t *Task) SetDelay(d time.Duration) *Task

Jul 10, 2024

Changes in this version

+ func CompareSpoke(sp1, sp2 *Spoke) int

type Task

+ func NewTaskJob(d time.Duration, job Job) *Task

Jul 9, 2024

Changes in this version

type Task

+ func (t *Task) Activated() bool

Jul 2, 2024

Changes in this version

+ const DefaultTimeUnit

type Spoke

+ func (sp *Spoke) Delay() int64

Jun 28, 2024

Changes in this version

+ const DefaultTickMs

+ const DefaultWheelSize

+ var ErrClosed = errors.New("timer: use of closed timer")

+ func IsPowOf2(x int) bool

+ func NextPowOf2(x int) int

+ type GoPool interface

+ Go func(f func())

+ type Job interface

+ Run func()

+ type JobFunc func()

+ func (f JobFunc) Run()

+ type Option func(*Timer)

+ func WithGoPool(p GoPool) Option

+ func WithTickMs(tickMs int64) Option

+ func WithWheelSize(size int) Option

+ type Spoke struct

+ func NewSpoke(taskCounter *atomic.Int64) *Spoke

+ func (sp *Spoke) Add(task *Task)

+ func (sp *Spoke) CompareTo(sp2 queue.Comparable) int

+ func (sp *Spoke) DelayMs() int64

+ func (sp *Spoke) Flush(f func(*Task))

+ func (sp *Spoke) GetExpiration() int64

+ func (sp *Spoke) Remove(task *Task)

+ func (sp *Spoke) SetExpiration(expirationMs int64) bool

+ type Task struct

+ func NewTask(d time.Duration) *Task

+ func NewTaskFunc(d time.Duration, f func()) *Task

+ func (t *Task) Cancel()

+ func (t *Task) Cancelled() bool

+ func (t *Task) Delay() time.Duration

+ func (t *Task) ExpirationMs() int64

+ func (t *Task) Run()

+ func (t *Task) WithJob(j Job) *Task

+ func (t *Task) WithJobFunc(f func()) *Task

+ type Timer struct

+ func NewTimer(opts ...Option) *Timer

+ func (t *Timer) AddTask(task *Task) error

+ func (t *Timer) AfterFunc(d time.Duration, f func()) (*Task, error)

+ func (t *Timer) Start()

+ func (t *Timer) Started() bool

+ func (t *Timer) Stop()

+ func (t *Timer) TaskCounter() int64

+ func (t *Timer) TickMs() int64

+ func (t *Timer) WheelMask() int

+ func (t *Timer) WheelSize() int

+ type TimingWheel struct