rlptools

Documentation

Index

• func ApplyOverrides(topology *kuadrantgatewayapi.Topology, gateway *gatewayapiv1.Gateway) (*kuadrantgatewayapi.Topology, error)
• func Equal(a, b RateLimitList) bool
• func LimitadorRateLimitsFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) []limitadorv1alpha1.RateLimit
• func LimitsNameFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) string
• func LimitsNamespaceFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) string
• func TopologyIndexesFromGateway(ctx context.Context, cl client.Client, gw *gatewayapiv1.Gateway) (*kuadrantgatewayapi.TopologyIndexes, error)
• type RateLimitIndex
  • func NewRateLimitIndex() *RateLimitIndex
  • func (l *RateLimitIndex) Set(key RateLimitIndexKey, rateLimits RateLimitList)
  • func (l *RateLimitIndex) ToRateLimits() RateLimitList
• type RateLimitIndexKey
• type RateLimitList
  • func (l RateLimitList) Len() int
  • func (l RateLimitList) Less(i, j int) bool
  • func (l RateLimitList) Swap(i, j int)

Functions

func ApplyOverrides

func ApplyOverrides(topology *kuadrantgatewayapi.Topology, gateway *gatewayapiv1.Gateway) (*kuadrantgatewayapi.Topology, error)

ApplyOverrides applies the overrides defined in the RateLimitPolicies attached to the gateway policies for a given gateway, and returns a new topology with all policies overridden as applicable.

func Equal

func Equal(a, b RateLimitList) bool

func LimitadorRateLimitsFromRLP

func LimitadorRateLimitsFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) []limitadorv1alpha1.RateLimit

LimitadorRateLimitsFromRLP converts rate limits from a Kuadrant RateLimitPolicy into a list of Limitador rate limit objects

func LimitsNameFromRLP

func LimitsNameFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) string

func LimitsNamespaceFromRLP

func LimitsNamespaceFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) string

func TopologyIndexesFromGateway

func TopologyIndexesFromGateway(ctx context.Context, cl client.Client, gw *gatewayapiv1.Gateway) (*kuadrantgatewayapi.TopologyIndexes, error)

Types

type RateLimitIndex

type RateLimitIndex struct {
	orderedmap.OrderedMap[RateLimitIndexKey, RateLimitList]
}

RateLimitIndex stores RateLimitLists by key

func NewRateLimitIndex

func NewRateLimitIndex() *RateLimitIndex

NewRateLimitIndex builds an index to manage sets of rate limits, organized by key

func (*RateLimitIndex) Set

func (l *RateLimitIndex) Set(key RateLimitIndexKey, rateLimits RateLimitList)

func (*RateLimitIndex) ToRateLimits

func (l *RateLimitIndex) ToRateLimits() RateLimitList

type RateLimitIndexKey

type RateLimitIndexKey struct {
	RateLimitPolicyKey types.NamespacedName
	GatewayKey         types.NamespacedName
}

type RateLimitList

type RateLimitList []limitadorv1alpha1.RateLimit

func (RateLimitList) Len

func (l RateLimitList) Len() int

func (RateLimitList) Less

func (l RateLimitList) Less(i, j int) bool

func (RateLimitList) Swap

func (l RateLimitList) Swap(i, j int)