loadscheduler

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

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

func (*Actuator) IsActuator() bool

IsActuator implements runtime.Component.

func (*Actuator) Name

func (*Actuator) Name() string

Name implements runtime.Component.

func (*Actuator) ShortDescription

func (la *Actuator) ShortDescription() string

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

func (*Scheduler) IsActuator() bool

IsActuator implements runtime.Component.

func (*Scheduler) Name

func (*Scheduler) Name() string

Name implements runtime.Component.

func (*Scheduler) ShortDescription

func (s *Scheduler) ShortDescription() string

ShortDescription implements runtime.Component.

func (*Scheduler) Type

func (*Scheduler) Type() runtime.ComponentType

Type implements runtime.Component.