common

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 13, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KuadrantRateLimitClusterName         = "kuadrant-rate-limiting-service"
	HTTPRouteKind                        = "HTTPRoute"
	KuadrantRateLimitPolicyRefAnnotation = "kuadrant.io/ratelimitpolicies"
	RateLimitPolicyBackRefAnnotation     = "kuadrant.io/ratelimitpolicy-direct-backref"
	AuthPolicyBackRefAnnotation          = "kuadrant.io/authpolicy-backref"
	KuadrantNamespaceLabel               = "kuadrant.io/namespace"
	NamespaceSeparator                   = '/'
	LimitadorName                        = "limitador"
)

TODO: move the const to a proper place, or get it from config

View Source 
const (
	DeleteTagAnnotation      = "kuadrant.io/delete"
	ReadyStatusConditionType = "Ready"
)

Variables

This section is empty.

Functions

func AnnotateObject added in v0.2.0 

func AnnotateObject(obj client.Object, namespace string)

func ConditionMarshal 

func ConditionMarshal(conditions []metav1.Condition) ([]byte, error)

ConditionMarshal marshals the set of conditions as a JSON array, sorted by condition type.

func Contains added in v0.2.0 

func Contains(slice []string, target string) bool

func ContainsObjectKey added in v0.2.0 

func ContainsObjectKey(a []client.ObjectKey, x client.ObjectKey) bool

ContainsObjectKey tells whether a contains x

func CopyConditions 

func CopyConditions(conditions []metav1.Condition) []metav1.Condition

CopyConditions copies the set of conditions

func DecodeFile 

func DecodeFile(ctx context.Context, fileData []byte, scheme *runtime.Scheme, cb DecodeCallback) error

func DeleteKuadrantAnnotationFromGateway added in v0.2.0 

func DeleteKuadrantAnnotationFromGateway(gw *gatewayapiv1alpha2.Gateway, namespace string)

func FetchEnv 

func FetchEnv(key string, def string) string

func FindAuthorinoStatusCondition 

func FindAuthorinoStatusCondition(conditions []authorinov1beta1.Condition, conditionType string) *authorinov1beta1.Condition

func FindDeploymentStatusCondition 

func FindDeploymentStatusCondition(conditions []appsv1.DeploymentCondition, conditionType string) *appsv1.DeploymentCondition

func FindObjectKey added in v0.2.0 

func FindObjectKey(a []client.ObjectKey, x client.ObjectKey) int

FindObjectKey returns the smallest index i at which x == a[i], or len(a) if there is no such index.

func GetDefaultIfNil added in v0.2.0 

func GetDefaultIfNil[T any](val *T, def T) T

func GetKuadrantNamespace added in v0.2.0 

func GetKuadrantNamespace(obj client.Object) (string, error)

func GetNamespaceFromPolicy added in v0.2.0 

func GetNamespaceFromPolicy(policy KuadrantPolicy) (string, bool)

func GetNamespaceFromPolicyTargetRef added in v0.2.0 

func GetNamespaceFromPolicyTargetRef(ctx context.Context, cli client.Client, policy KuadrantPolicy) (string, error)

func GetServicePortNumber added in v0.2.0 

func GetServicePortNumber(ctx context.Context, k8sClient client.Client, svcKey client.ObjectKey, svcPort string) (int32, error)

GetServicePortNumber returns the port number from the referenced key and port info the port info can be named port or already a number.

func GetWASMShimImageVersion added in v0.2.0 

func GetWASMShimImageVersion() string

func HostnamesToStrings added in v0.2.0 

func HostnamesToStrings(hostnames []gatewayapiv1alpha2.Hostname) []string

converts []gatewayapi_v1alpha2.Hostname to []string

func IsKuadrantManaged added in v0.2.0 

func IsKuadrantManaged(obj client.Object) bool

func IsObjectTaggedToDelete 

func IsObjectTaggedToDelete(obj client.Object) bool

func IsOwnedBy 

func IsOwnedBy(owned, owner client.Object) bool

func IsTargetRefGateway added in v0.2.0 

func IsTargetRefGateway(targetRef gatewayapiv1alpha2.PolicyTargetReference) bool

func IsTargetRefHTTPRoute added in v0.2.0 

func IsTargetRefHTTPRoute(targetRef gatewayapiv1alpha2.PolicyTargetReference) bool

func MarshallNamespace added in v0.2.0 

func MarshallNamespace(gwKey client.ObjectKey, domain string) string

MarshallNamespace serializes limit namespace with format "gwNS/gwName#domain"

func MergeMapStringString added in v0.2.0 

func MergeMapStringString(existing *map[string]string, desired map[string]string) bool

MergeMapStringString Merge desired into existing. Not Thread-Safe. Does it matter?

func NamespacedNameToObjectKey added in v0.2.0 

func NamespacedNameToObjectKey(namespacedName, defaultNamespace string) client.ObjectKey

NamespacedNameToObjectKey converts <namespace/name> format string to k8s object key. It's common for K8s to reference an object using this format. For e.g. gateways in VirtualService.

func ObjectInfo 

func ObjectInfo(obj client.Object) string

func ObjectKeyListDifference 

func ObjectKeyListDifference(a, b []client.ObjectKey) []client.ObjectKey

ObjectKeyListDifference computest a - b

func RouteHTTPMethodToRuleMethod added in v0.2.0 

func RouteHTTPMethodToRuleMethod(httpMethod *gatewayapiv1alpha2.HTTPMethod) []string

func RouteHostnames added in v0.2.0 

func RouteHostnames(route *gatewayapiv1alpha2.HTTPRoute) []string

func StatusConditionsMarshalJSON added in v0.2.0 

func StatusConditionsMarshalJSON(input []metav1.Condition) ([]byte, error)

StatusConditionsMarshalJSON marshals the list of conditions as a JSON array, sorted by condition type.

func TagObjectToDelete 

func TagObjectToDelete(obj client.Object)

func UnMarshallLimitNamespace added in v0.2.0 

func UnMarshallLimitNamespace(ns string) (client.ObjectKey, string, error)

UnMarshallLimitNamespace parses limit namespace with format "gwNS/gwName#domain"

func UnMarshallObjectKey added in v0.2.0 

func UnMarshallObjectKey(keyStr string) (client.ObjectKey, error)

func ValidSubdomains added in v0.2.0 

func ValidSubdomains(domains, subdomains []string) (bool, string)

ValidSubdomains returns (true, "") when every single subdomains item is a subset of at least one of the domains. Domains and subdomains may be prefixed with a wildcard label (*.). The wildcard label must appear by itself as the first label. When one of the subdomains is not a subset of any of the domains, it returns false and the subdomain not being subset of any of the domains

Types

type DecodeCallback 

type DecodeCallback = func(runtime.Object) error

type HTTPRouteRule added in v0.2.0 

type HTTPRouteRule struct {
	Paths   []string
	Methods []string
	Hosts   []string
}

func RulesFromHTTPRoute added in v0.2.0 

func RulesFromHTTPRoute(route *gatewayapiv1alpha2.HTTPRoute) []HTTPRouteRule

RulesFromHTTPRoute computes a list of rules from the HTTPRoute object

type KuadrantPolicy added in v0.2.0 

type KuadrantPolicy interface {
	client.Object
	GetTargetRef() gatewayapiv1alpha2.PolicyTargetReference
	GetWrappedNamespace() gatewayapiv1alpha2.Namespace
}

type Name added in v0.2.0 

type Name string

Name describes a (possibly wildcarded) hostname

func (Name) IsWildCarded added in v0.2.0 

func (n Name) IsWildCarded() bool

func (Name) String added in v0.2.0 

func (n Name) String() string

func (Name) SubsetOf added in v0.2.0 

func (n Name) SubsetOf(o Name) bool

SubsetOf returns true if this hostname is a valid subset of the other hostname. The semantics are the same as "Matches", but only in one direction (i.e., h is covered by o).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.