concurrencyscheduler

Documentation

Index

• func NewConcurrencySchedulerAndOptions(concurrencySchedulerProto *policyprivatev1.ConcurrencyScheduler, ...) (runtime.Component, fx.Option, error)
• func NewConfigSyncOptions(concurrencySchedulerProto *policylangv1.ConcurrencyScheduler, ...) (fx.Option, error)
• func ParseConcurrencyScheduler(concurrencyScheduler *policylangv1.ConcurrencyScheduler, ...) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)

Functions

func NewConcurrencySchedulerAndOptions

func NewConcurrencySchedulerAndOptions(
	concurrencySchedulerProto *policyprivatev1.ConcurrencyScheduler,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (runtime.Component, fx.Option, error)

NewConcurrencySchedulerAndOptions creates fx options for ConcurrencyScheduler.

func NewConfigSyncOptions

func NewConfigSyncOptions(
	concurrencySchedulerProto *policylangv1.ConcurrencyScheduler,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (fx.Option, error)

NewConfigSyncOptions creates fx options for syncing LoadScheduler objects with agent groups.

func ParseConcurrencyScheduler

func ParseConcurrencyScheduler(
	concurrencyScheduler *policylangv1.ConcurrencyScheduler,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)

ParseConcurrencyScheduler parses a ConcurrencyScheduler component and returns a configured component and a nested circuit.