scheduler

README

Scheduler

Scheduler rus, configures and stops goroutines Should know nothing about K8s. It uses protobuf generated objects only for the sake of simplicity

Documentation

Index

• type Schedule
  • func New(outsideHandler runner.Handler) *Schedule
  • func (s *Schedule) Destroy(name string) error
  • func (s *Schedule) Handle(ctx context.Context, msg *runner.Msg) error
  • func (s *Schedule) HandleInternal(ctx context.Context, msg *runner.Msg) error
  • func (s *Schedule) Install(component module.Component) error
  • func (s *Schedule) SetLogger(l logr.Logger) *Schedule
  • func (s *Schedule) SetManager(m resource.ManagerInterface) *Schedule
  • func (s *Schedule) SetMeter(m metric.Meter) *Schedule
  • func (s *Schedule) SetTracer(t trace.Tracer) *Schedule
  • func (s *Schedule) SetTracker(t tracker.Manager) *Schedule
  • func (s *Schedule) Start(ctx context.Context) error
  • func (s *Schedule) Update(ctx context.Context, node *v1alpha1.TinyNode) error
• type Scheduler

Types

type Schedule

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

func New

func New(outsideHandler runner.Handler) *Schedule

func (*Schedule) Destroy

func (s *Schedule) Destroy(name string) error

func (*Schedule) Handle

func (s *Schedule) Handle(ctx context.Context, msg *runner.Msg) error

Handle could be external and synchronous

func (*Schedule) HandleInternal

func (s *Schedule) HandleInternal(ctx context.Context, msg *runner.Msg) error

HandleInternal only local and async

func (*Schedule) Install

func (s *Schedule) Install(component module.Component) error

func (*Schedule) SetLogger

func (s *Schedule) SetLogger(l logr.Logger) *Schedule

func (*Schedule) SetManager

func (s *Schedule) SetManager(m resource.ManagerInterface) *Schedule

func (*Schedule) SetMeter

func (s *Schedule) SetMeter(m metric.Meter) *Schedule

func (*Schedule) SetTracer

func (s *Schedule) SetTracer(t trace.Tracer) *Schedule

func (*Schedule) SetTracker

func (s *Schedule) SetTracker(t tracker.Manager) *Schedule

func (*Schedule) Start

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

func (*Schedule) Update

func (s *Schedule) Update(ctx context.Context, node *v1alpha1.TinyNode) error

Update updates node instance or creates one

type Scheduler

type Scheduler interface {
	//Install makes component available to run instances
	Install(component module.Component) error

	//Update creates a new instance by using unique name, if instance exists - updates one
	Update(ctx context.Context, node *v1alpha1.TinyNode) error

	Handle(ctx context.Context, msg *runner.Msg) error
	//HandleInternal same as Handle but does not wait until port unblock and does not fall back msg outside
	HandleInternal(ctx context.Context, msg *runner.Msg) error
	//Destroy stops the instance and deletes it
	Destroy(name string) error
	//Start starts scheduler
	Start(ctx context.Context) error
}