common

Documentation

Index

• Constants
• Variables
• func Contains(slice []string, target string) bool
• func FetchEnv(key string, def string) string
• func GetServicePortNumber(ctx context.Context, k8sClient client.Client, svcKey client.ObjectKey, ...) (int32, error)
• func IsObjectTaggedToDelete(obj client.Object) bool
• func IsOwnedBy(owned, owner client.Object) bool
• func MergeMapStringString(existing *map[string]string, desired map[string]string) bool
• func NamespacedNameToObjectKey(namespacedName, defaultNamespace string) client.ObjectKey
• func ObjectInfo(obj client.Object) string
• func StatusConditionsMarshalJSON(input []metav1.Condition) ([]byte, error)
• func TagObjectToDelete(obj client.Object)
• type RateLimitFactory
  • func (r *RateLimitFactory) RateLimit() *limitadorv1alpha1.RateLimit

Constants

const (
	KuadrantNamespace             = "kuadrant-system"
	KuadrantAuthorizationProvider = "kuadrant-authorization"
	LimitadorServiceGrpcPort      = 8081
)

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

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

Variables

var (
	LimitadorServiceClusterHost = fmt.Sprintf("limitador.%s.svc.cluster.local", KuadrantNamespace)
)

Functions

func Contains

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

func FetchEnv

func FetchEnv(key string, def string) string

func GetServicePortNumber

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 IsObjectTaggedToDelete

func IsObjectTaggedToDelete(obj client.Object) bool

func IsOwnedBy

func IsOwnedBy(owned, owner client.Object) bool

func MergeMapStringString

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

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

func NamespacedNameToObjectKey

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 StatusConditionsMarshalJSON

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)

Types

type RateLimitFactory

type RateLimitFactory struct {
	Key        client.ObjectKey
	Conditions []string
	MaxValue   int
	Namespace  string
	Seconds    int
	Variables  []string
}

func (*RateLimitFactory) RateLimit

func (r *RateLimitFactory) RateLimit() *limitadorv1alpha1.RateLimit