scheduler

Documentation

Index

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

Functions

func NewScheduler

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

Types

type Scheduler

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

func (*Scheduler) AddFunc

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

func (*Scheduler) Remove

func (c *Scheduler) Remove(id scheduler.EntryID)

func (*Scheduler) Shutdown

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

func (*Scheduler) Start

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