The highest tagged major version is
Documentation
¶
Index ¶
- func NewActuatorAndOptions(actuatorProto *policylangv1.LoadScheduler_Actuator, componentID string, ...) (runtime.Component, fx.Option, error)
- func NewLoadSchedulerOptions(loadSchedulerProto *policylangv1.LoadScheduler, componentStackID string, ...) (fx.Option, []string, error)
- func NewSchedulerAndOptions(schedulerProto *policylangv1.LoadScheduler_Scheduler, componentID string, ...) (runtime.Component, fx.Option, error)
- func ParseAdaptiveLoadScheduler(adaptiveLoadScheduler *policylangv1.AdaptiveLoadScheduler) (*policylangv1.NestedCircuit, error)
- type Actuator
- func (la *Actuator) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
- func (la *Actuator) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)
- func (*Actuator) IsActuator() bool
- func (*Actuator) Name() string
- func (la *Actuator) ShortDescription() string
- func (*Actuator) Type() runtime.ComponentType
- type Scheduler
- func (s *Scheduler) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
- func (s *Scheduler) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)
- func (*Scheduler) IsActuator() bool
- func (*Scheduler) Name() string
- func (s *Scheduler) ShortDescription() string
- func (*Scheduler) Type() runtime.ComponentType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewActuatorAndOptions ¶
func NewActuatorAndOptions( actuatorProto *policylangv1.LoadScheduler_Actuator, componentID string, policyReadAPI iface.Policy, agentGroups []string, ) (runtime.Component, fx.Option, error)
NewActuatorAndOptions creates load actuator and its fx options.
func NewLoadSchedulerOptions ¶
func NewLoadSchedulerOptions( loadSchedulerProto *policylangv1.LoadScheduler, componentStackID string, policyReadAPI iface.Policy, ) (fx.Option, []string, error)
NewLoadSchedulerOptions creates fx options for LoadScheduler and also returns the agent group name associated with it.
func NewSchedulerAndOptions ¶
func NewSchedulerAndOptions( schedulerProto *policylangv1.LoadScheduler_Scheduler, componentID string, policyReadAPI iface.Policy, agentGroups []string, ) (runtime.Component, fx.Option, error)
NewSchedulerAndOptions creates scheduler and its fx options.
func ParseAdaptiveLoadScheduler ¶
func ParseAdaptiveLoadScheduler( adaptiveLoadScheduler *policylangv1.AdaptiveLoadScheduler, ) (*policylangv1.NestedCircuit, error)
ParseAdaptiveLoadScheduler parses and returns nested circuit representation of AdaptiveLoadScheduler.
Types ¶
type Actuator ¶
type Actuator struct {
// contains filtered or unexported fields
}
Actuator struct.
func (*Actuator) DynamicConfigUpdate ¶
func (la *Actuator) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
DynamicConfigUpdate finds the dynamic config and syncs the decision to agent.
func (*Actuator) Execute ¶
func (la *Actuator) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)
Execute implements runtime.Component.Execute.
func (*Actuator) IsActuator ¶
IsActuator implements runtime.Component.
func (*Actuator) ShortDescription ¶
ShortDescription implements runtime.Component.
func (*Actuator) Type ¶
func (*Actuator) Type() runtime.ComponentType
Type implements runtime.Component.
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler is part of the LoadScheduler component stack.
func (*Scheduler) DynamicConfigUpdate ¶
func (s *Scheduler) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
DynamicConfigUpdate is a no-op for this component.
func (*Scheduler) Execute ¶
func (s *Scheduler) Execute(inPortReadings runtime.PortToReading, tickInfo runtime.TickInfo) (runtime.PortToReading, error)
Execute implements runtime.Component.Execute.
func (*Scheduler) IsActuator ¶
IsActuator implements runtime.Component.
func (*Scheduler) ShortDescription ¶
ShortDescription implements runtime.Component.
func (*Scheduler) Type ¶
func (*Scheduler) Type() runtime.ComponentType
Type implements runtime.Component.
Source Files