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() *Schedule
  • func (s *Schedule) Destroy(name string) error
  • func (s *Schedule) Install(component module.Component) error
  • func (s *Schedule) Invoke(ctx context.Context, node string, port string, data []byte) error
  • func (s *Schedule) SetLogger(l logr.Logger) *Schedule
  • func (s *Schedule) SetManager(m manager.ResourceInterface) *Schedule
  • func (s *Schedule) Start(ctx context.Context, wg *errgroup.Group, eventBus chan *runner.Msg, ...) error
  • func (s *Schedule) Upsert(node *v1alpha1.TinyNode) error
• type Scheduler

Types

type Schedule

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

func New

func New() *Schedule

func (*Schedule) Destroy

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

func (*Schedule) Install

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

func (*Schedule) Invoke

func (s *Schedule) Invoke(ctx context.Context, node string, port string, data []byte) error

Invoke sends data to the port of given instance name @todo

func (*Schedule) SetLogger

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

func (*Schedule) SetManager

func (s *Schedule) SetManager(m manager.ResourceInterface) *Schedule

func (*Schedule) Start

func (s *Schedule) Start(ctx context.Context, wg *errgroup.Group, eventBus chan *runner.Msg, outsideCh chan *runner.Msg, callbacks ...tracker.Callback) error

func (*Schedule) Upsert

func (s *Schedule) Upsert(node *v1alpha1.TinyNode) error

Upsert updates or creates instance

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(node *v1alpha1.TinyNode) error
	//Invoke sends data to the port of the given instance
	Invoke(ctx context.Context, name string, port string, data []byte) error
	//Destroy stops the instance
	Destroy(name string) error
	//Start starts scheduler
	Start(ctx context.Context, wg *errgroup.Group, inputCh chan *runner.Msg, outputCh chan *runner.Msg, callbacks ...tracker.Callback) error
}