Documentation
¶
Index ¶
- func NewActuatorAndOptions(actuatorProto *policyprivatev1.LoadActuator, _ runtime.ComponentID, ...) (runtime.Component, fx.Option, error)
- func NewConfigSyncOptions(loadSchedulerProto *policylangv1.LoadScheduler, ...) (fx.Option, error)
- func ParseAdaptiveLoadScheduler(adaptiveLoadScheduler *policylangv1.AdaptiveLoadScheduler) (*policylangv1.NestedCircuit, error)
- func ParseLoadScheduler(loadScheduler *policylangv1.LoadScheduler, componentID runtime.ComponentID, ...) (*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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewActuatorAndOptions ¶
func NewActuatorAndOptions( actuatorProto *policyprivatev1.LoadActuator, _ runtime.ComponentID, policyReadAPI iface.Policy, ) (runtime.Component, fx.Option, error)
NewActuatorAndOptions creates load actuator and its fx options.
func NewConfigSyncOptions ¶
func NewConfigSyncOptions( loadSchedulerProto *policylangv1.LoadScheduler, componentID runtime.ComponentID, policyReadAPI iface.Policy, ) (fx.Option, error)
NewConfigSyncOptions creates fx options for syncing LoadScheduler objects with agent groups.
func ParseAdaptiveLoadScheduler ¶
func ParseAdaptiveLoadScheduler( adaptiveLoadScheduler *policylangv1.AdaptiveLoadScheduler, ) (*policylangv1.NestedCircuit, error)
ParseAdaptiveLoadScheduler parses and returns nested circuit representation of AdaptiveLoadScheduler.
func ParseLoadScheduler ¶
func ParseLoadScheduler( loadScheduler *policylangv1.LoadScheduler, componentID runtime.ComponentID, policyReadAPI iface.Policy, ) (*policylangv1.NestedCircuit, error)
ParseLoadScheduler parses a load scheduler from a spec.
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.
Click to show internal directories.
Click to hide internal directories.