Versions in this module Expand all Collapse all v0 v0.0.5 Jan 23, 2026 v0.0.4 Dec 1, 2025 Changes in this version + type HeapTaskPool struct + func NewHeapTaskPool(now base.FNNow) *HeapTaskPool + func (tp *HeapTaskPool) AddTask(key string, t time.Time, exec TaskFunc, params ...interface{}) error + func (tp *HeapTaskPool) RemoveTask(key string) error + func (tp *HeapTaskPool) Start() + func (tp *HeapTaskPool) Stop() + type OpType int + type ScheduleTaskPool interface + AddTask func(key string, t time.Time, exec TaskFunc, params ...any) error + RemoveTask func(key string) error + Stop func() + func CreateHeapTaskPool() ScheduleTaskPool + func CreateHeapTaskPoolWithFNNow(now base.FNNow) ScheduleTaskPool + type TaskFunc func(key string, args ...any)