Versions in this module Expand all Collapse all v0 v0.2.0 May 15, 2026 Changes in this version + type Engine struct + func NewEngine(handler JobHandler, maxConcurrent int) *Engine + func (e *Engine) AddJob(job *Job) error + func (e *Engine) EnableJob(id string, enabled bool) + func (e *Engine) ListJobs() []*Job + func (e *Engine) MarshalJSON() ([]byte, error) + func (e *Engine) RemoveJob(id string) + func (e *Engine) Start() + func (e *Engine) Status() map[string]interface{} + func (e *Engine) Stop() + type Job struct + ConsecutiveErrors int + CreatedAt time.Time + DeleteAfterRun bool + Description string + Enabled bool + ID string + LastRunAt *time.Time + LastStatus RunStatus + MaxRetries int + Name string + NextRunAt *time.Time + Payload string + Schedule Schedule + SessionTarget SessionTarget + type JobHandler func(job *Job) error + type RunRecord struct + DurationMs int64 + Error string + JobID string + Status RunStatus + Timestamp time.Time + type RunStatus string + const StatusError + const StatusOK + const StatusSkipped + type Schedule struct + At *time.Time + Every time.Duration + Kind ScheduleKind + type ScheduleKind string + const ScheduleAt + const ScheduleEvery + type SessionTarget string + const SessionIsolated + const SessionMain
Go to main page