util

Documentation

Index

• Constants
• func ApplyLabelsAndAnnotations(input cli.Input, objectMeta *metav1.ObjectMeta) error
• func CheckFunctionExistence(ctx context.Context, client cmd.Client, functions []string, fnNamespace string) (err error)
• func CheckHTTPTriggerDuplicates(ctx context.Context, client cmd.Client, t *fv1.HTTPTrigger) error
• func ConfigMapExists(ctx context.Context, m *metav1.ObjectMeta, kClient kubernetes.Interface) error
• func FunctionPodLogs(ctx context.Context, fnName, ns string, client cmd.Client) (err error)
• func GetApplicationUrl(ctx context.Context, client cmd.Client, selector string) (string, error)
• func GetEnvVarFromStringSlice(params []string) []v1.EnvVar
• func GetFissionNamespace() string
• func GetResourceReqs(input cli.Input, resReqs *v1.ResourceRequirements) (*v1.ResourceRequirements, error)
• func GetRouterURL(ctx context.Context, cmdClient cmd.Client) (serverURL *url.URL, err error)
• func GetServerInfo(input cli.Input, cmdClient cmd.Client) *info.ServerInfo
• func GetSpecDir(input cli.Input) string
• func GetSpecIgnore(input cli.Input) string
• func GetSpecIgnoreParser(specDir, specIgnore string) (ignore.IgnoreParser, error)
• func GetStorageURL(ctx context.Context, client cmd.Client) (*url.URL, error)
• func GetValidationFlag(input cli.Input) bool
• func GetVersion(ctx context.Context, input cli.Input, cmdClient cmd.Client) info.Versions
• func IsNotFound(err error) bool
• func KubifyName(old string) string
• func ParseAnnotations(annotations []string) (map[string]string, error)
• func ResolveFunctionNS(namespace string) string
• func SecretExists(ctx context.Context, m *metav1.ObjectMeta, kClient kubernetes.Interface) error
• func SetupPortForward(ctx context.Context, client cmd.Client, namespace, labelSelector string) (string, error)
• func UpdateMapFromStringSlice(dataMap *map[string]string, params []string) bool
• func UrlForFunction(name, namespace string) string

Constants

const (
	SPEC_IGNORE_FILE          = ".specignore"
	COMMIT_LABEL              = "commit"
	FISSION_AUTH_URI          = "/auth/login"
	FISSION_AUTH_TOKEN        = "FISSION_AUTH_TOKEN"
	FISSION_STORAGE_URI       = "/v1/archive"
	FISSION_DEFAULT_NAMESPACE = "fission"
	SOURCE_ARCHIVE            = "source"
	DEPLOY_ARCHIVE            = "deploy"
)

fission-cli options

const (
	ENV_FISSION_NAMESPACE  string = "FISSION_NAMESPACE"
	ENV_FISSION_URL        string = "FISSION_URL"
	ENV_FISSION_AUTH_TOKEN string = "FISSION_AUTH_TOKEN"
)

const (
	ENV_FUNCTION_NAMESPACE string = "FUNCTION_NAMESPACE"
)

Functions

func ApplyLabelsAndAnnotations

func ApplyLabelsAndAnnotations(input cli.Input, objectMeta *metav1.ObjectMeta) error

func CheckFunctionExistence

func CheckFunctionExistence(ctx context.Context, client cmd.Client, functions []string, fnNamespace string) (err error)

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

func CheckHTTPTriggerDuplicates

func CheckHTTPTriggerDuplicates(ctx context.Context, client cmd.Client, t *fv1.HTTPTrigger) error

CheckHTTPTriggerDuplicates checks whether the tuple (Method, Host, URL) is duplicate or not.

func ConfigMapExists

func ConfigMapExists(ctx context.Context, m *metav1.ObjectMeta, kClient kubernetes.Interface) error

func FunctionPodLogs

func FunctionPodLogs(ctx context.Context, fnName, ns string, client cmd.Client) (err error)

FunctionPodLogs : Get logs for a function directly from pod

func GetApplicationUrl

func GetApplicationUrl(ctx context.Context, client cmd.Client, selector string) (string, error)

func GetEnvVarFromStringSlice

func GetEnvVarFromStringSlice(params []string) []v1.EnvVar

GetEnvVarFromStringSlice parses key, val from "key=val" string array and updates passed []v1.EnvVar

func GetFissionNamespace

func GetFissionNamespace() string

func GetResourceReqs

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

func GetRouterURL

func GetRouterURL(ctx context.Context, cmdClient cmd.Client) (serverURL *url.URL, err error)

func GetServerInfo

func GetServerInfo(input cli.Input, cmdClient cmd.Client) *info.ServerInfo

func GetSpecDir

func GetSpecDir(input cli.Input) string

func GetSpecIgnore

func GetSpecIgnore(input cli.Input) string

func GetSpecIgnoreParser

func GetSpecIgnoreParser(specDir, specIgnore string) (ignore.IgnoreParser, error)

GetSpecIgnoreParser reads the specignore file and returns the ignore.IgnoreParser if the specignore file does not exist it returns empty ignore.IgnoreParser

func GetStorageURL

func GetStorageURL(ctx context.Context, client cmd.Client) (*url.URL, error)

func GetValidationFlag

func GetValidationFlag(input cli.Input) bool

func GetVersion

func GetVersion(ctx context.Context, input cli.Input, cmdClient cmd.Client) info.Versions

func IsNotFound

func IsNotFound(err error) bool

func KubifyName

func KubifyName(old string) string

KubifyName make a kubernetes compliant name out of an arbitrary string

func ParseAnnotations

func ParseAnnotations(annotations []string) (map[string]string, error)

func ResolveFunctionNS

func ResolveFunctionNS(namespace string) string

func SecretExists

func SecretExists(ctx context.Context, m *metav1.ObjectMeta, kClient kubernetes.Interface) error

func SetupPortForward

func SetupPortForward(ctx context.Context, client cmd.Client, 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.

func UpdateMapFromStringSlice

func UpdateMapFromStringSlice(dataMap *map[string]string, params []string) bool

UpdateMapFromStringSlice parses key, val from "key=val" string array and updates passed map

func UrlForFunction

func UrlForFunction(name, namespace string) string