utils

package
Version: v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 12, 2021 License: Apache-2.0 Imports: 22 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildOutOfClusterConfig

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

BuildOutOfClusterConfig returns k8s config

func CreateHTTPTriggerCustomResource

func CreateHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTrigger *httptriggerapi.HTTPTrigger) error

CreateHTTPTriggerCustomResource will create a HTTP trigger custom resource object

func CreateIngress

func CreateIngress(client kubernetes.Interface, httpTriggerObj *kubelessApi.HTTPTrigger, or []metav1.OwnerReference) error

CreateIngress creates ingress rule for a specific function

func DeleteHTTPTriggerCustomResource

func DeleteHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTriggerName, ns string) error

DeleteHTTPTriggerCustomResource will delete HTTP trigger custom resource object

func DeleteIngress

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

DeleteIngress deletes an ingress rule

func GetClient

func GetClient() kubernetes.Interface

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

func GetFunctionClientInCluster

func GetFunctionClientInCluster() (versioned.Interface, error)

GetFunctionClientInCluster returns function clientset to the request from inside of cluster

func GetHTTPReq

func GetHTTPReq(clientset kubernetes.Interface, funcName, namespace, eventNamespace, method, body string) (*http.Request, error)

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

func GetHTTPTriggerCustomResource

func GetHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTriggerName, ns string) (*httptriggerapi.HTTPTrigger, error)

GetHTTPTriggerCustomResource will get HTTP trigger custom resource object

func GetKubelessClientOutCluster

func GetKubelessClientOutCluster() (versioned.Interface, error)

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

func GetLocalHostname

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

GetLocalHostname returns hostname

func GetTriggerClientInCluster

func GetTriggerClientInCluster() (versioned.Interface, error)

GetTriggerClientInCluster returns function clientset to the request from inside of cluster

func IsJSON

func IsJSON(s string) bool

IsJSON returns true if the string is json

func PatchHTTPTriggerCustomResource

func PatchHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTrigger *httptriggerapi.HTTPTrigger) error

PatchHTTPTriggerCustomResource applies changes to the function custom object

func SendMessage

func SendMessage(req *http.Request) error

SendMessage sends messge over function service

func UpdateHTTPTriggerCustomResource

func UpdateHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTrigger *httptriggerapi.HTTPTrigger) error

UpdateHTTPTriggerCustomResource applies changes to the HTTP trigger custom resource object

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL