concurrency

Documentation

Index

• func NewConcurrencyLimiterOptions(concurrencyLimiterProto *policylangv1.ConcurrencyLimiter, ...) (fx.Option, string, error)
• func NewLoadShedActuatorAndOptions(_ *policylangv1.LoadShedActuator, componentIndex int, ...) (runtime.Component, fx.Option, error)
• func NewSchedulerAndOptions(schedulerProto *policylangv1.Scheduler, componentIndex int, ...) (runtime.Component, fx.Option, error)
• type LoadShedActuator
  • func (lsa *LoadShedActuator) Execute(inPortReadings runtime.PortToValue, tickInfo runtime.TickInfo) (runtime.PortToValue, error)
• type Scheduler
  • func (s *Scheduler) Execute(inPortReadings runtime.PortToValue, tickInfo runtime.TickInfo) (runtime.PortToValue, error)

Functions

func NewConcurrencyLimiterOptions

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

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

func NewLoadShedActuatorAndOptions

func NewLoadShedActuatorAndOptions(
	_ *policylangv1.LoadShedActuator,
	componentIndex int,
	policyReadAPI iface.Policy,
	agentGroupName string,
) (runtime.Component, fx.Option, error)

NewLoadShedActuatorAndOptions creates load shed 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 LoadShedActuator

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

LoadShedActuator struct.

func (*LoadShedActuator) Execute

func (lsa *LoadShedActuator) 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) Execute

func (s *Scheduler) Execute(inPortReadings runtime.PortToValue, tickInfo runtime.TickInfo) (runtime.PortToValue, error)

Execute implements runtime.Component.Execute.