ratelimiter

Documentation

Index

• func NewConfigSyncOptions(rateLimiterProto *policylangv1.RateLimiter, componentID runtime.ComponentID, ...) (fx.Option, error)
• func NewRateLimiterAndOptions(rateLimiterProto *policyprivatev1.RateLimiter, componentID runtime.ComponentID, ...) (runtime.Component, fx.Option, error)
• func ParseRateLimiter(rateLimiter *policylangv1.RateLimiter, componentID runtime.ComponentID, ...) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)

Functions

func NewConfigSyncOptions

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

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

func NewRateLimiterAndOptions

func NewRateLimiterAndOptions(
	rateLimiterProto *policyprivatev1.RateLimiter,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (runtime.Component, fx.Option, error)

NewRateLimiterAndOptions creates fx options for RateLimiter.

func ParseRateLimiter

func ParseRateLimiter(
	rateLimiter *policylangv1.RateLimiter,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (*runtime.ConfiguredComponent, *policylangv1.NestedCircuit, error)

ParseRateLimiter parses a RateLimiter component and returns a configured component and a nested circuit.