scheduler

Documentation

Overview

Package scheduler handles the scheduling of tasks

Index

• type Scheduler
  • func New(st *store.Store) Scheduler
  • func (s *Scheduler) EnableScheduler(ctx context.Context) <-chan error
  • func (s *Scheduler) StartScheduler(startTime int64)
  • func (s *Scheduler) WakeScheduler()

Types

type Scheduler

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

Scheduler is struct on which all scheduler functionality is implemented.

func New

func New(st *store.Store) Scheduler

New returns a new scheduler

func (*Scheduler) EnableScheduler

func (s *Scheduler) EnableScheduler(ctx context.Context) <-chan error

EnableScheduler enables the scheduler this will wait until StartScheduler() is called, after that it will poll the store queue for changes and write errors to a 3-buffered channel

func (*Scheduler) StartScheduler

func (s *Scheduler) StartScheduler(startTime int64)

StartScheduler sets the start time and starts the scheduler

func (*Scheduler) WakeScheduler

func (s *Scheduler) WakeScheduler()

WakeScheduler wakes up the scheduler