scheduler

Documentation

Index

• type Scheduler
  • func New() (s *Scheduler)
  • func (s *Scheduler) Run(ctx context.Context) (err error)
  • func (s *Scheduler) Stop()

Types

type Scheduler

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

Scheduler schedule the pipeline. allocate the pipeline to the appropriate node for operation

func New

func New() (s *Scheduler)

New returns a new Scheduler

func (*Scheduler) Run

func (s *Scheduler) Run(ctx context.Context) (err error)

Run start working

func (*Scheduler) Stop

func (s *Scheduler) Stop()

Stop stop working