Documentation
¶
Index ¶
- func BuildOutOfClusterConfig() (*rest.Config, error)
- func CreateHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTrigger *httptriggerapi.HTTPTrigger) error
- func CreateIngress(client kubernetes.Interface, httpTriggerObj *kubelessApi.HTTPTrigger, ...) error
- func DeleteHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTriggerName, ns string) error
- func DeleteIngress(client kubernetes.Interface, name, ns string) error
- func GetClient() kubernetes.Interface
- func GetFunctionClientInCluster() (versioned.Interface, error)
- func GetHTTPReq(clientset kubernetes.Interface, ...) (*http.Request, error)
- func GetHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTriggerName, ns string) (*httptriggerapi.HTTPTrigger, error)
- func GetKubelessClientOutCluster() (versioned.Interface, error)
- func GetLocalHostname(config *rest.Config, funcName string) (string, error)
- func GetTriggerClientInCluster() (versioned.Interface, error)
- func IsJSON(s string) bool
- func PatchHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTrigger *httptriggerapi.HTTPTrigger) error
- func SendMessage(req *http.Request) error
- func UpdateHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTrigger *httptriggerapi.HTTPTrigger) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildOutOfClusterConfig ¶
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 ¶
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 ¶
GetKubelessClientOutCluster returns kubeless clientset to make kubeless API request from outside of cluster
func GetLocalHostname ¶
GetLocalHostname returns hostname
func GetTriggerClientInCluster ¶
GetTriggerClientInCluster returns function clientset to the request from inside of cluster
func PatchHTTPTriggerCustomResource ¶
func PatchHTTPTriggerCustomResource(kubelessClient versioned.Interface, httpTrigger *httptriggerapi.HTTPTrigger) error
PatchHTTPTriggerCustomResource applies changes to the function custom object
func SendMessage ¶
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.
Source Files