BuildOutOfClusterConfig returns k8s config.

CreateAutoscale creates HPA object for function.

CreateCronJobCustomResource will create a custom function object.

CreateFunctionCustomResource will create a custom function object.

CreateHTTPTriggerCustomResource will create a HTTP trigger custom resource object.

CreateIngress creates ingress rule for a specific function.

CreateKafkaTriggerCustomResource will create a custom function object.

CreateNatsTriggerCustomResource will create a custom function object.

CreateServiceMonitor creates a Service Monitor for the given function.

DeleteAutoscale deletes an autoscale rule.

DeleteCronJobCustomResource will delete custom function object.

DeleteFunctionCustomResource will delete custom function object.

DeleteHTTPTriggerCustomResource will delete HTTP trigger custom resource object.

DeleteIngress deletes an ingress rule.

DeleteKafkaTriggerCustomResource will delete custom function object.

DeleteNatsTriggerCustomResource will delete custom function object.

DeleteServiceMonitor cleans the sm if it exists.

EnsureCronJob creates/updates a function cron job.

EnsureFuncConfigMap creates/updates a config map with a function specification.

EnsureFuncDeployment creates/updates a function deployment.

EnsureFuncImage creates a Job to build a function image.

EnsureFuncService creates/updates a function service.

Exec returns an "exec" Request suitable for ExecRoundTripper.

ExecRoundTripper creates a wrapped WebsocketRoundTripper.

FunctionObjAddFinalizer add specified finalizer string to function object.

FunctionObjHasFinalizer checks if function object already has the Function controller finalizer.

FunctionObjRemoveFinalizer removes the finalizer from the function object.

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.

GetConfigLocation returns a map which has information on the namespace where Kubeless controller is installed and the name of the ConfigMap which stores kubeless configurations.

GetCronJobCustomResource will get CronJobTrigger custom resource object.

GetCronJobTriggerOwnerReference returns ownerRef for appending to objects's metadata created by kubeless-controller one a function is deployed.

GetDefaultNamespace returns the namespace set in current cluster context.

GetFunction returns specification of a function.

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

GetFunctionCustomResource will delete custom function object.

GetFunctionOwnerReference returns ownerRef for appending to objects's metadata created by kubeless-controller once a function is deployed.

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

GetHTTPTriggerCustomResource will get HTTP trigger custom resource object.

GetHTTPTriggerOwnerReference returns ownerRef for appending to objects's metadata created by kubeless-controller one a function is deployed.

GetKafkaTriggerCustomResource will get CronJobTrigger custom resource object.

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

GetLocalHostname returns hostname.

GetNatsTriggerCustomResource will get CronJobTrigger custom resource object.

GetPodsByLabel returns list of pods which match the label We use this to returns pods to which the function is deployed or pods running controllers.

GetRandString returns a random string of lenght N.

GetReadyPod returns the first pod has passed the liveness probe check.

IsJSON returns true if the string is json.

MergeDeployments merges two deployment objects.

PatchFunctionCustomResource applies changes to the function custom object.

PatchHTTPTriggerCustomResource applies changes to the function custom object.

SendMessage sends messge over function service.

UpdateCronJobCustomResource applies changes to the function custom object.

UpdateFunctionCustomResource applies changes to the function custom object.

UpdateHTTPTriggerCustomResource applies changes to the HTTP trigger custom resource object.

UpdateKafkaTriggerCustomResource applies changes to the function custom object.

UpdateNatsTriggerCustomResource applies changes to the function custom object.

Cmd stores information relevant to an individual remote command being run.

ConfigLocation is a struct to store the location of kubeless configuration specific ConfigMap.

WebsocketRoundTripper is an http.RoundTripper that invokes a callback on a websocket connection.

A RoundTripCallback is used to process the websocket from an individual command execution.