utils

Documentation

Index

• func BuildOutOfClusterConfig() (*rest.Config, error)
• func CreateAutoscale(client kubernetes.Interface, funcObj *spec.Function, ns, metric string, ...) error
• func CreateIngress(client kubernetes.Interface, funcObj *spec.Function, ...) error
• func CreateK8sCustomResource(crdClient rest.Interface, f *spec.Function) error
• func DeleteAutoscale(client kubernetes.Interface, name, ns string) error
• func DeleteIngress(client kubernetes.Interface, name, ns string) error
• func DeleteK8sCustomResource(crdClient *rest.RESTClient, funcName, ns string) error
• func DeleteServiceMonitor(name, ns string) error
• func EnsureFuncConfigMap(client kubernetes.Interface, funcObj *spec.Function, ...) error
• func EnsureFuncCronJob(client rest.Interface, funcObj *spec.Function, or []metav1.OwnerReference, ...) error
• func EnsureFuncDeployment(client kubernetes.Interface, funcObj *spec.Function, ...) error
• func EnsureFuncService(client kubernetes.Interface, funcObj *spec.Function, ...) error
• func Exec(client corev1.CoreV1Interface, pod, namespace string, opts v1.PodExecOptions) (*http.Request, error)
• func ExecRoundTripper(conf *rest.Config, f RoundTripCallback) (http.RoundTripper, error)
• func GetCRDClient() (*rest.RESTClient, error)
• func GetCRDClientOutOfCluster() (*rest.RESTClient, error)
• func GetClient() kubernetes.Interface
• func GetClientOutOfCluster() kubernetes.Interface
• func GetDefaultNamespace() string
• func GetFunction(funcName, ns string) (spec.Function, error)
• func GetLocalHostname(config *rest.Config, funcName string) (string, error)
• func GetOwnerReference(funcObj *spec.Function) ([]metav1.OwnerReference, error)
• func GetPodsByLabel(c kubernetes.Interface, ns, k, v string) (*v1.PodList, error)
• func GetReadyPod(pods *v1.PodList) (v1.Pod, error)
• func GetRestClient() (*rest.RESTClient, error)
• func GetRestClientOutOfCluster(group, apiVersion, apiPath string) (*rest.RESTClient, error)
• func GetServiceMonitorClientOutOfCluster() (*monitoringv1alpha1.MonitoringV1alpha1Client, error)
• func UpdateK8sCustomResource(crdClient rest.Interface, f *spec.Function) error
• type Cmd
  • func (c *Cmd) RoundTripCallback(conn *websocket.Conn) (*http.Response, error)
• type RoundTripCallback
• type WebsocketRoundTripper
  • func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)

Functions

func BuildOutOfClusterConfig

func BuildOutOfClusterConfig() (*rest.Config, error)

BuildOutOfClusterConfig returns k8s config

func CreateAutoscale

func CreateAutoscale(client kubernetes.Interface, funcObj *spec.Function, ns, metric string, min, max int32, value string) error

CreateAutoscale creates HPA object for function

func CreateIngress

func CreateIngress(client kubernetes.Interface, funcObj *spec.Function, ingressName, hostname, ns string, enableTLSAcme bool) error

CreateIngress creates ingress rule for a specific function

func CreateK8sCustomResource

func CreateK8sCustomResource(crdClient rest.Interface, f *spec.Function) error

CreateK8sCustomResource will create a custom function object

func DeleteAutoscale

func DeleteAutoscale(client kubernetes.Interface, name, ns string) error

DeleteAutoscale deletes an autoscale rule

func DeleteIngress

func DeleteIngress(client kubernetes.Interface, name, ns string) error

DeleteIngress deletes an ingress rule

func DeleteK8sCustomResource

func DeleteK8sCustomResource(crdClient *rest.RESTClient, funcName, ns string) error

DeleteK8sCustomResource will delete custom function object

func DeleteServiceMonitor

func DeleteServiceMonitor(name, ns string) error

DeleteServiceMonitor cleans the sm if it exists

func EnsureFuncConfigMap

func EnsureFuncConfigMap(client kubernetes.Interface, funcObj *spec.Function, or []metav1.OwnerReference) error

EnsureFuncConfigMap creates/updates a config map with a function specification

func EnsureFuncCronJob

func EnsureFuncCronJob(client rest.Interface, funcObj *spec.Function, or []metav1.OwnerReference, groupVersion string) error

EnsureFuncCronJob creates/updates a function cron job

func EnsureFuncDeployment

func EnsureFuncDeployment(client kubernetes.Interface, funcObj *spec.Function, or []metav1.OwnerReference) error

EnsureFuncDeployment creates/updates a function deployment

func EnsureFuncService

func EnsureFuncService(client kubernetes.Interface, funcObj *spec.Function, or []metav1.OwnerReference) error

EnsureFuncService creates/updates a function service

func Exec

func Exec(client corev1.CoreV1Interface, pod, namespace string, opts v1.PodExecOptions) (*http.Request, error)

Exec returns an "exec" Request suitable for ExecRoundTripper.

func ExecRoundTripper

func ExecRoundTripper(conf *rest.Config, f RoundTripCallback) (http.RoundTripper, error)

ExecRoundTripper creates a wrapped WebsocketRoundTripper

func GetCRDClient

func GetCRDClient() (*rest.RESTClient, error)

GetCRDClient returns crd client to the request from inside of cluster

func GetCRDClientOutOfCluster

func GetCRDClientOutOfCluster() (*rest.RESTClient, error)

GetCRDClientOutOfCluster returns crd client to the request from outside of cluster

func GetClient

func GetClient() kubernetes.Interface

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

func GetClientOutOfCluster

func GetClientOutOfCluster() kubernetes.Interface

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

func GetDefaultNamespace

func GetDefaultNamespace() string

GetDefaultNamespace returns the namespace set in current cluster context

func GetFunction

func GetFunction(funcName, ns string) (spec.Function, error)

GetFunction returns specification of a function

func GetLocalHostname

func GetLocalHostname(config *rest.Config, funcName string) (string, error)

GetLocalHostname returns hostname

func GetOwnerReference

func GetOwnerReference(funcObj *spec.Function) ([]metav1.OwnerReference, error)

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

func GetPodsByLabel

func GetPodsByLabel(c kubernetes.Interface, ns, k, v string) (*v1.PodList, error)

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

func GetReadyPod

func GetReadyPod(pods *v1.PodList) (v1.Pod, error)

GetReadyPod returns the first pod has passed the liveness probe check

func GetRestClient

func GetRestClient() (*rest.RESTClient, error)

GetRestClient returns a k8s restclient to the request from inside of cluster

func GetRestClientOutOfCluster

func GetRestClientOutOfCluster(group, apiVersion, apiPath string) (*rest.RESTClient, error)

GetRestClientOutOfCluster returns a REST client based on a group, API version and path

func GetServiceMonitorClientOutOfCluster

func GetServiceMonitorClientOutOfCluster() (*monitoringv1alpha1.MonitoringV1alpha1Client, error)

GetServiceMonitorClientOutOfCluster returns sm client to the request from outside of cluster

func UpdateK8sCustomResource

func UpdateK8sCustomResource(crdClient rest.Interface, f *spec.Function) error

UpdateK8sCustomResource applies changes to the function custom object

Types

type Cmd

type Cmd struct {
	Stdin  io.Reader
	Stdout io.Writer
	Stderr io.Writer
}

Cmd stores information relevant to an individual remote command being run

func (*Cmd) RoundTripCallback

func (c *Cmd) RoundTripCallback(conn *websocket.Conn) (*http.Response, error)

RoundTripCallback is suitable to use with `ExecRoundTripper` and will copy data to/from stdio channels. The returned `Response` is currently always `nil`.

type RoundTripCallback

type RoundTripCallback func(conn *websocket.Conn) (*http.Response, error)

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

type WebsocketRoundTripper

type WebsocketRoundTripper struct {
	TLSConfig *tls.Config
	Do        RoundTripCallback
}

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

func (*WebsocketRoundTripper) RoundTrip

func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip implements the http.RoundTripper interface.