scheduler

Documentation

Index

• type EntryID
• type Scheduler
  • func NewScheduler(lc fx.Lifecycle, adaptors *adaptors.Adaptors, eventBus bus.Bus) (scheduler *Scheduler, err error)
  • func (c *Scheduler) AddFunc(spec string, cmd func()) (id EntryID, err error)
  • func (c *Scheduler) Remove(id EntryID)
  • func (c *Scheduler) Shutdown(_ context.Context) error
  • func (c *Scheduler) Start(ctx context.Context) error

Types

type EntryID

type EntryID int

type Scheduler

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

func NewScheduler

func NewScheduler(lc fx.Lifecycle,
	adaptors *adaptors.Adaptors,
	eventBus bus.Bus) (scheduler *Scheduler, err error)

func (*Scheduler) AddFunc

func (c *Scheduler) AddFunc(spec string, cmd func()) (id EntryID, err error)

func (*Scheduler) Remove

func (c *Scheduler) Remove(id EntryID)

func (*Scheduler) Shutdown

func (c *Scheduler) Shutdown(_ context.Context) error

func (*Scheduler) Start

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