util

Documentation

Index

• func CheckFunctionExistence(client client.Interface, functions []string, fnNamespace string) (err error)
• func GetApplicationUrl(selector string) (string, error)
• func GetFissionNamespace() string
• func GetKubernetesClient() (*restclient.Config, *kubernetes.Clientset, error)
• func GetResourceReqs(input cli.Input, resReqs *v1.ResourceRequirements) (*v1.ResourceRequirements, error)
• func GetServer(input cli.Input) (c client.Interface, err error)
• func GetServerURL(input cli.Input) (serverUrl string, err error)
• func GetSpecDir(input cli.Input) string
• func GetVersion(client client.Interface) info.Versions
• func KubifyName(old string) string
• func SetupPortForward(namespace, labelSelector string) (string, error)

Functions

func CheckFunctionExistence

func CheckFunctionExistence(client client.Interface, functions []string, fnNamespace string) (err error)

given a list of functions, this checks if the functions actually exist on the cluster

func GetApplicationUrl

func GetApplicationUrl(selector string) (string, error)

func GetFissionNamespace

func GetFissionNamespace() string

func GetKubernetesClient

func GetKubernetesClient() (*restclient.Config, *kubernetes.Clientset, error)

GetKubernetesClient builds a new kubernetes client. If the KUBECONFIG environment variable is empty or doesn't exist, ~/.kube/config is used for the kube config path

func GetResourceReqs

func GetResourceReqs(input cli.Input, resReqs *v1.ResourceRequirements) (*v1.ResourceRequirements, error)

func GetServer

func GetServer(input cli.Input) (c client.Interface, err error)

func GetServerURL

func GetServerURL(input cli.Input) (serverUrl string, err error)

func GetSpecDir

func GetSpecDir(input cli.Input) string

func GetVersion

func GetVersion(client client.Interface) info.Versions

func KubifyName

func KubifyName(old string) string

KubifyName make a kubernetes compliant name out of an arbitrary string

func SetupPortForward

func SetupPortForward(namespace, labelSelector string) (string, error)

Port forward a free local port to a pod on the cluster. The pod is found in the specified namespace by labelSelector. The pod's port is found by looking for a service in the same namespace and using its targetPort. Once the port forward is started, wait for it to start accepting connections before returning.