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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.