events

Oct 7, 2023

Changes in this version

+ func Initial()

+ func OnEvent(event Event)

+ func RemoveJob(id EntryID)

+ func StartEventManager()

+ func StartJobManager()

+ func StopEventManager()

+ func StopJobManager()

+ type EntryID = cron.EntryID

+ func OnTask(s cron.Schedule, fn JobFn) EntryID

+ func Schedule(job Job) EntryID

+ type Event = event.Event

+ type EventManager interface

+ OnEvent func(event Event)

+ Start func()

+ Stop func()

+ func NewEventManager(fn pool.RespFn[Event], opts ...pool.Option) EventManager

+ type Job interface

+ func NewJob(s cron.Schedule, fn JobFn) Job

+ type JobFn func()

+ func (fn JobFn) Run()

+ type JobManager interface

+ Remove func(id EntryID)

+ Schedule func(Job) EntryID

+ Start func()

+ Stop func()

+ func NewJobManager() JobManager