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) (any, 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
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) Handle ¶ added in v0.1.53
Handle could be external and synchronous @todo use retry with backoff here
func (*Schedule) SetManager ¶ added in v0.1.25
func (s *Schedule) SetManager(m resource.ManagerInterface) *Schedule
func (*Schedule) SetTracker ¶ added in v0.1.65
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 using its specs and signals
Update(ctx context.Context, node *v1alpha1.TinyNode) error
//Handle sync incoming call
Handle(ctx context.Context, msg *runner.Msg) (any, error)
//Destroy stops the instance and deletes it
Destroy(name string) error
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.