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 (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) Start(ctx context.Context) error
- func (s *Schedule) Update(ctx context.Context, node *v1alpha1.TinyNode) error
- type Scheduler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Schedule ¶
type Schedule struct {
// contains filtered or unexported fields
}
func (*Schedule) HandleInternal ¶ added in v0.1.63
HandleInternal only local and async
func (*Schedule) SetManager ¶ added in v0.1.25
func (s *Schedule) SetManager(m resource.ManagerInterface) *Schedule
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 fallback 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
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.