concurrencylimiter

Documentation

Index

• func NewConcurrencyLimiterAndOptions(concurrencyLimiterProto *policyprivatev1.ConcurrencyLimiter, ...) (runtime.Component, fx.Option, error)
• func NewConfigSyncOptions(concurrencyLimiterProto *policylangv1.ConcurrencyLimiter, ...) (fx.Option, error)
• func ParseConcurrencyLimiter(concurrencyLimiter *policylangv1.ConcurrencyLimiter, ...) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)

Functions

func NewConcurrencyLimiterAndOptions

func NewConcurrencyLimiterAndOptions(
	concurrencyLimiterProto *policyprivatev1.ConcurrencyLimiter,
	_ runtime.ComponentID,
	policyReadAPI iface.Policy,
) (runtime.Component, fx.Option, error)

NewConcurrencyLimiterAndOptions creates fx options for ConcurrencyLimiter.

func NewConfigSyncOptions

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

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

func ParseConcurrencyLimiter

func ParseConcurrencyLimiter(
	concurrencyLimiter *policylangv1.ConcurrencyLimiter,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)

ParseConcurrencyLimiter parses a ConcurrencyLimiter component and returns a configured component and a nested circuit.