concurrency

Documentation

Index

• func NewConcurrencyLimiterOptions(concurrencyLimiterProto *policylangv1.ConcurrencyLimiter, ...) (fx.Option, string, error)
• func NewLoadActuatorAndOptions(loadActuatorProto *policylangv1.LoadActuator, componentIndex int, ...) (runtime.Component, fx.Option, error)
• func NewSchedulerAndOptions(schedulerProto *policylangv1.Scheduler, componentIndex int, ...) (runtime.Component, fx.Option, error)
• type LoadActuator
  • func (la *LoadActuator) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
  • func (la *LoadActuator) Execute(inPortReadings runtime.PortToValue, tickInfo runtime.TickInfo) (runtime.PortToValue, error)
• type Scheduler
  • func (s *Scheduler) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)
  • func (s *Scheduler) Execute(inPortReadings runtime.PortToValue, tickInfo runtime.TickInfo) (runtime.PortToValue, error)

Functions

func NewConcurrencyLimiterOptions

func NewConcurrencyLimiterOptions(
	concurrencyLimiterProto *policylangv1.ConcurrencyLimiter,
	componentStackIndex int,
	policyReadAPI iface.Policy,
) (fx.Option, string, error)

NewConcurrencyLimiterOptions creates fx options for ConcurrencyLimiter and also returns the agent group name associated with it.

func NewLoadActuatorAndOptions

func NewLoadActuatorAndOptions(
	loadActuatorProto *policylangv1.LoadActuator,
	componentIndex int,
	policyReadAPI iface.Policy,
	agentGroup string,
) (runtime.Component, fx.Option, error)

NewLoadActuatorAndOptions creates load actuator and its fx options.

func NewSchedulerAndOptions

func NewSchedulerAndOptions(
	schedulerProto *policylangv1.Scheduler,
	componentIndex int,
	policyReadAPI iface.Policy,
	agentGroupName string,
) (runtime.Component, fx.Option, error)

NewSchedulerAndOptions creates scheduler and its fx options.

Types

type LoadActuator

type LoadActuator struct {
	// contains filtered or unexported fields
}

LoadActuator struct.

func (*LoadActuator) DynamicConfigUpdate

func (la *LoadActuator) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller)

DynamicConfigUpdate finds the dynamic config and syncs the decision to agent.

func (*LoadActuator) Execute

func (la *LoadActuator) Execute(inPortReadings runtime.PortToValue, tickInfo runtime.TickInfo) (runtime.PortToValue, error)

Execute implements runtime.Component.Execute.

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

Scheduler is part of the concurrency control 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.PortToValue, tickInfo runtime.TickInfo) (runtime.PortToValue, error)

Execute implements runtime.Component.Execute.