rlptools

Documentation

Index

• Constants
• Variables
• func Equal(a, b RateLimitList) bool
• func LimitNameToLimitadorIdentifier(uniqueLimitName string) string
• func LimitadorRateLimitsFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) []limitadorv1alpha1.RateLimit
• func LimitsNamespaceFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) string
• func WASMPluginFromStruct(structure *_struct.Struct) (*wasm.Plugin, error)
• func WASMPluginMutator(existingObj, desiredObj client.Object) (bool, error)
• func WasmRules(rlp *kuadrantv1beta2.RateLimitPolicy, route *gatewayapiv1beta1.HTTPRoute) []wasm.Rule
• 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)
• type WasmRulesByDomain

Constants

const (
	LimitadorRateLimitIdentifierPrefix = "limit."
)

Variables

var (
	WASMFilterImageURL = env.GetString("RELATED_IMAGE_WASMSHIM", "oci://quay.io/kuadrant/wasm-shim:latest")
)

Functions

func Equal

func Equal(a, b RateLimitList) bool

func LimitNameToLimitadorIdentifier

func LimitNameToLimitadorIdentifier(uniqueLimitName string) string

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 LimitsNamespaceFromRLP

func LimitsNamespaceFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) string

func WASMPluginFromStruct

func WASMPluginFromStruct(structure *_struct.Struct) (*wasm.Plugin, error)

func WASMPluginMutator

func WASMPluginMutator(existingObj, desiredObj client.Object) (bool, error)

func WasmRules

func WasmRules(rlp *kuadrantv1beta2.RateLimitPolicy, route *gatewayapiv1beta1.HTTPRoute) []wasm.Rule

WasmRules computes WASM rules from the policy and the targeted route. It returns an empty list of wasm rules if the policy specifies no limits or if all limits specified in the policy fail to match any route rule according to the limits route selectors.

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 = client.ObjectKey

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)

type WasmRulesByDomain

type WasmRulesByDomain map[string][]wasm.Rule