schedule

package

v1.1.0 Latest Latest Go to latest Published: Apr 30, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrTaskAdded    = errors.New("task already added")
	ErrTaskNotFound = errors.New("task not found")
)

This section is empty.

type CronScheduler struct {
	// contains filtered or unexported fields
}

CronScheduler is a scheduler implemented by robfig/cron

func NewCronScheduler() *CronScheduler

func (s *CronScheduler) Name() string

func (s *CronScheduler) RunNow(name string)

func (s *CronScheduler) Schedule(task Task)

func (s *CronScheduler) Start() error

Start starts the cron scheduler.

func (s *CronScheduler) Stop(ctx context.Context) error

Stop stops the cron scheduler and waits for running tasks to complete.

type IntervalSchedule struct {
	InitialDelay time.Duration
	Interval     time.Duration
	// contains filtered or unexported fields
}

func NewIntervalSchedule(initialDelay time.Duration, interval time.Duration) *IntervalSchedule

func (m *IntervalSchedule) Next(t time.Time) time.Time

type Schedule interface {
	Next(time.Time) time.Time
}

type Scheduler interface {
	Schedule(Task)
	RunNow(name string)
	Start() error
	Stop(context.Context) error
}

Scheduler manages scheduled tasks

type Task struct {
	Name      string
	Scheduled Schedule
	Run       func(ctx context.Context) error
}