BuildOutOfClusterConfig returns k8s config.

CreateAutoscale creates HPA object for function.

CreateKafkaTriggerCustomResource will create a custom function object.

DeleteAutoscale deletes an autoscale rule.

DeleteKafkaTriggerCustomResource will delete custom function object.

DeleteServiceMonitor cleans the sm if it exists.

GetAnnotationsFromCRD gets annotations from a CustomResourceDefinition.

GetAPIExtensionsClientInCluster returns a k8s clientset to access APIExtensions from inside of cluster.

GetAPIExtensionsClientOutOfCluster returns a k8s clientset to access APIExtensions from outside of cluster.

GetClient returns a k8s clientset to the request from inside of cluster.

GetClientOutOfCluster returns a k8s clientset to the request from outside of cluster.

GetFunctionPort returns the port for a function service.

GetHTTPReq returns the http request object that can be used to send a event with payload to function service.

GetKafkaTriggerCustomResource will get CronJobTrigger custom resource object.

GetKubelessClientOutCluster returns kubeless clientset to make kubeless API request from outside of cluster.

GetRandString returns a random string of lenght N.

GetSecretsAsLocalObjectReference returns a list of LocalObjectReference based on secret names.

GetTriggerClientInCluster returns function clientset to the request from inside of cluster.

IsJSON returns true if the string is json.

MergeDeployments merges two deployment objects.

SendMessage sends messge over function service.

UpdateKafkaTriggerCustomResource applies changes to the function custom object.