rlptools

Sep 18, 2024

Changes in this version

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

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

type RateLimitIndexKey

+ GatewayKey types.NamespacedName

+ RateLimitPolicyKey types.NamespacedName

Nov 28, 2023

Changes in this version

+ func LimitsNameFromRLP(rlp *kuadrantv1beta2.RateLimitPolicy) string

+ func WASMPluginName(gw *gatewayapiv1.Gateway) string

Oct 24, 2023

Changes in this version

+ const LimitadorRateLimitIdentifierPrefix

+ 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 WasmRules(rlp *kuadrantv1beta2.RateLimitPolicy, route *gatewayapiv1beta1.HTTPRoute) []wasm.Rule

+ type RateLimitIndex struct

+ func NewRateLimitIndex() *RateLimitIndex

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

+ func (l *RateLimitIndex) ToRateLimits() RateLimitList

+ type RateLimitIndexKey = client.ObjectKey

+ type RateLimitList []limitadorv1alpha1.RateLimit

+ func (l RateLimitList) Len() int

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

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

+ type WasmRulesByDomain map[string][]wasm.Rule

May 5, 2023

Changes in this version

+ func DefaultGatewayConfiguration(key client.ObjectKey) []kuadrantv1beta1.Configuration

Dec 13, 2022

Changes in this version

+ var WASMFilterImageURL = common.FetchEnv("WASM_FILTER_IMAGE", "oci://quay.io/kuadrant/wasm-shim:latest")

+ func HTTPRouteRulesToRLPRules(httpRouteRules []common.HTTPRouteRule) []kuadrantv1beta1.Rule

+ func SameLimitList(a, b []kuadrantv1beta1.Limit) bool

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

+ type GatewayAction struct

+ Configurations []kuadrantv1beta1.Configuration

+ Rules []kuadrantv1beta1.Rule

+ func GatewayActionsFromRateLimitPolicy(rlp *kuadrantv1beta1.RateLimitPolicy, route *gatewayapiv1alpha2.HTTPRoute) []GatewayAction

+ type GatewayActionsByDomain map[string][]GatewayAction

+ func (g GatewayActionsByDomain) String() string

+ type GatewayWrapper struct

+ func LeftGateways(gwList *gatewayapiv1alpha2.GatewayList, rlpKey client.ObjectKey, ...) []GatewayWrapper

+ func NewGateways(gwList *gatewayapiv1alpha2.GatewayList, rlpKey client.ObjectKey, ...) []GatewayWrapper

+ func SameGateways(gwList *gatewayapiv1alpha2.GatewayList, rlpKey client.ObjectKey, ...) []GatewayWrapper

+ func (g GatewayWrapper) AddRLP(rlpKey client.ObjectKey) bool

+ func (g GatewayWrapper) ContainsRLP(rlpKey client.ObjectKey) bool

+ func (g GatewayWrapper) DeleteRLP(rlpKey client.ObjectKey) bool

+ func (g GatewayWrapper) Hostnames() []string

+ func (g GatewayWrapper) Key() client.ObjectKey

+ func (g GatewayWrapper) RLPRefs() []client.ObjectKey

+ type LimitIndex struct

+ func NewLimitadorIndex(limitador *limitadorv1alpha1.Limitador, logger logr.Logger) *LimitIndex

+ func (l *LimitIndex) AddGatewayLimits(gwKey client.ObjectKey, gwLimits LimitsByDomain)

+ func (l *LimitIndex) AddLimit(gwKey client.ObjectKey, domain string, limit *kuadrantv1beta1.Limit)

+ func (l *LimitIndex) AddLimitFromRateLimit(limit *limitadorv1alpha1.RateLimit)

+ func (l *LimitIndex) DeleteGateway(gwKey client.ObjectKey)

+ func (l *LimitIndex) Equals(other *LimitIndex) bool

+ func (l *LimitIndex) ToLimits() []limitadorv1alpha1.RateLimit

+ type LimitList []kuadrantv1beta1.Limit

+ func (l LimitList) Len() int

+ func (l LimitList) Less(i, j int) bool

+ func (l LimitList) Swap(i, j int)

+ type LimitsByDomain map[string][]kuadrantv1beta1.Limit

+ func (l LimitsByDomain) Equals(other LimitsByDomain) bool

+ func (l LimitsByDomain) String() string

+ type RateLimitPolicy struct

+ GatewayActions []GatewayAction

+ Hostnames []string

+ Name string

+ RateLimitDomain string

+ UpstreamCluster string

+ type WASMPlugin struct

+ FailureModeDeny bool

+ RateLimitPolicies []RateLimitPolicy

+ func WASMPluginFromStruct(structure *_struct.Struct) (*WASMPlugin, error)

+ func (w *WASMPlugin) ToStruct() (*_struct.Struct, error)