Documentation
¶
Index ¶
- func BuildOutOfClusterConfig() (*rest.Config, error)
- func CreateNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTrigger *natsApi.NATSTrigger) error
- func DeleteNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTriggerName, ns string) error
- func GetClient() kubernetes.Interface
- func GetFunctionPort(clientset kubernetes.Interface, namespace, functionName string) (string, error)
- func GetHTTPReq(clientset kubernetes.Interface, ...) (*http.Request, error)
- func GetKubelessClientOutCluster() (versioned.Interface, error)
- func GetNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTriggerName, ns string) (*natsApi.NATSTrigger, error)
- func GetTriggerClientInCluster() (versioned.Interface, error)
- func IsJSON(s string) bool
- func SendMessage(req *http.Request) error
- func UpdateNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTrigger *natsApi.NATSTrigger) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildOutOfClusterConfig ¶
BuildOutOfClusterConfig returns k8s config
func CreateNatsTriggerCustomResource ¶
func CreateNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTrigger *natsApi.NATSTrigger) error
CreateNatsTriggerCustomResource will create a custom function object
func DeleteNatsTriggerCustomResource ¶
func DeleteNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTriggerName, ns string) error
DeleteNatsTriggerCustomResource will delete custom function object
func GetClient ¶
func GetClient() kubernetes.Interface
GetClient returns a k8s clientset to the request from inside of cluster
func GetFunctionPort ¶
func GetFunctionPort(clientset kubernetes.Interface, namespace, functionName string) (string, error)
GetFunctionPort returns the port for a function service
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 GetKubelessClientOutCluster ¶
GetKubelessClientOutCluster returns kubeless clientset to make kubeless API request from outside of cluster
func GetNatsTriggerCustomResource ¶
func GetNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTriggerName, ns string) (*natsApi.NATSTrigger, error)
GetNatsTriggerCustomResource will get CronJobTrigger custom resource object
func GetTriggerClientInCluster ¶
GetTriggerClientInCluster returns function clientset to the request from inside of cluster
func SendMessage ¶
SendMessage sends messge over function service
func UpdateNatsTriggerCustomResource ¶
func UpdateNatsTriggerCustomResource(kubelessClient versioned.Interface, natsTrigger *natsApi.NATSTrigger) error
UpdateNatsTriggerCustomResource applies changes to the function custom object
Types ¶
This section is empty.
Source Files