schedule

Documentation

Index

• type Scheduler
  • func New(ctx context.Context, conf *config.Config, logger *zap.Logger) (*Scheduler, error)
  • func (s *Scheduler) DiscardTaskNow(taskID string)
  • func (s *Scheduler) ScheduleTask(t *models.Task)
  • func (s *Scheduler) ScheduleTaskNow(t *models.Task) error
  • func (s *Scheduler) Start(ctx context.Context) error

Types

type Scheduler

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

func New

func New(ctx context.Context, conf *config.Config, logger *zap.Logger) (*Scheduler, error)

New creates a new scheduler instance. TODO: convert all the go-routines into effectiet using Select & For channel

func (*Scheduler) DiscardTaskNow

func (s *Scheduler) DiscardTaskNow(taskID string)

DiscardTaskNow removes a task from the scheduler and won't stops the task if it is running.

if the task is not found in scheduler, it logs a message.

func (*Scheduler) ScheduleTask

func (s *Scheduler) ScheduleTask(t *models.Task)

ScheduleTask schedules the task based on the start time.

func (*Scheduler) ScheduleTaskNow

func (s *Scheduler) ScheduleTaskNow(t *models.Task) error

It returns an error if the task is already scheduled.

func (*Scheduler) Start

func (s *Scheduler) Start(ctx context.Context) error

Start starts the scheduler. It schedules all the active tasks that read from the database.