Versions in this module Expand all Collapse all v0 v0.1.1 Oct 25, 2025 v0.1.0 Oct 14, 2025 Changes in this version + func GetTaskName(ctx context.Context) string + type CronSchedule struct + func Cron(expr string) *CronSchedule + func (c *CronSchedule) String() string + type CtxtKey string + type Option func(*TaskManager) + func WithAllowOverlapping(allow bool) Option + func WithContextInjector(injector func(ctx context.Context, taskName string) context.Context) Option + func WithContextValue(key string, value any) Option + func WithLocation(loc *time.Location) Option + func WithLogger(logger *log.Logger) Option + func WithMaxConcurrent(max int) Option + type Schedule interface + String func() string + type ScheduleBuilder struct + func Every() *ScheduleBuilder + func (s *ScheduleBuilder) At(hour, minute int) *ScheduleBuilder + func (s *ScheduleBuilder) Day() *ScheduleBuilder + func (s *ScheduleBuilder) Days(interval int) *ScheduleBuilder + func (s *ScheduleBuilder) Hour() *ScheduleBuilder + func (s *ScheduleBuilder) Hours(interval int) *ScheduleBuilder + func (s *ScheduleBuilder) Minute() *ScheduleBuilder + func (s *ScheduleBuilder) Minutes(interval int) *ScheduleBuilder + func (s *ScheduleBuilder) OnDay(day int) *ScheduleBuilder + func (s *ScheduleBuilder) OnWeekday(weekday time.Weekday) *ScheduleBuilder + func (s *ScheduleBuilder) Second() *ScheduleBuilder + func (s *ScheduleBuilder) Seconds(interval int) *ScheduleBuilder + func (s *ScheduleBuilder) String() string + type Task func(ctx context.Context) error + type TaskInfo struct + AddedAt time.Time + Enabled bool + EntryID cron.EntryID + ErrorCount int64 + LastError string + LastRun time.Time + Name string + NextRun time.Time + RunCount int64 + Running bool + Schedule string + Task Task + type TaskManager struct + func New(opts ...Option) *TaskManager + func (tm *TaskManager) AddTask(name string, schedule Schedule, task Task) error + func (tm *TaskManager) DisableTask(name string) error + func (tm *TaskManager) EnableTask(name string) error + func (tm *TaskManager) GetContextValue(key string) any + func (tm *TaskManager) GetStats() map[string]interface{} + func (tm *TaskManager) GetTask(name string) (*TaskInfo, error) + func (tm *TaskManager) IsRunning() bool + func (tm *TaskManager) ListTasks() []*TaskInfo + func (tm *TaskManager) RemoveTask(name string) error + func (tm *TaskManager) RunTaskNow(name string) error + func (tm *TaskManager) SetContextValue(key string, value any) + func (tm *TaskManager) Start() + func (tm *TaskManager) Stop() + func (tm *TaskManager) WebHandler(baseURL string) *http.ServeMux
Go to main page