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, callbacks ...tracker.Callback) *Schedule
  • func (s *Schedule) Destroy(name string) error
  • func (s *Schedule) Handle(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 manager.ResourceInterface) *Schedule
  • func (s *Schedule) SetMeter(m metric.Meter) *Schedule
  • func (s *Schedule) SetTracer(t trace.Tracer) *Schedule
  • func (s *Schedule) Start(ctx context.Context) error
  • func (s *Schedule) Upsert(ctx context.Context, node *v1alpha1.TinyNode) (err error)
• type Scheduler

Types

type Schedule

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

func New

func New(outsideHandler runner.Handler, callbacks ...tracker.Callback) *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 handles incoming

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 manager.ResourceInterface) *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) Start

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

func (*Schedule) Upsert

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

type Scheduler

type Scheduler interface {
	//Install makes component available for running nodes
	Install(component module.Component) error

	//Upsert creates a new instance by using unique name, if instance is already running - updates it
	Upsert(ctx context.Context, node *v1alpha1.TinyNode) error

	//Handle incoming
	Handle(ctx context.Context, msg *runner.Msg) error
	//Destroy stops the instance
	Destroy(name string) error
	//Start starts scheduler
	Start(ctx context.Context) error
}