Documentation
¶
Index ¶
- func BuildOutOfClusterConfig() (*rest.Config, error)
- func CreateKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTrigger *kinesisApi.KinesisTrigger) error
- func DeleteKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTriggerName, 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 GetKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTriggerName, ns string) (*kinesisApi.KinesisTrigger, error)
- func GetKubelessClientOutCluster() (versioned.Interface, error)
- func GetTriggerClientInCluster() (versioned.Interface, error)
- func IsJSON(s string) bool
- func PatchKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTrigger *kinesisApi.KinesisTrigger) error
- func SendMessage(req *http.Request) error
- func UpdateKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTrigger *kinesisApi.KinesisTrigger) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildOutOfClusterConfig ¶
BuildOutOfClusterConfig returns k8s config
func CreateKinesisTriggerCustomResource ¶
func CreateKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTrigger *kinesisApi.KinesisTrigger) error
CreateKinesisTriggerCustomResource will create a Kinesis trigger custom resource object
func DeleteKinesisTriggerCustomResource ¶
func DeleteKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTriggerName, ns string) error
DeleteKinesisTriggerCustomResource will delete HTTP trigger custom resource 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 GetKinesisTriggerCustomResource ¶
func GetKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTriggerName, ns string) (*kinesisApi.KinesisTrigger, error)
GetKinesisTriggerCustomResource will get HTTP trigger custom resource object
func GetKubelessClientOutCluster ¶
GetKubelessClientOutCluster returns kubeless clientset to make kubeless API request from outside of cluster
func GetTriggerClientInCluster ¶
GetTriggerClientInCluster returns function clientset to the request from inside of cluster
func PatchKinesisTriggerCustomResource ¶
func PatchKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTrigger *kinesisApi.KinesisTrigger) error
PatchKinesisTriggerCustomResource applies changes to the function custom object
func SendMessage ¶
SendMessage sends messge over function service
func UpdateKinesisTriggerCustomResource ¶
func UpdateKinesisTriggerCustomResource(kubelessClient versioned.Interface, kinesisTrigger *kinesisApi.KinesisTrigger) error
UpdateKinesisTriggerCustomResource applies changes to the Kinesis trigger custom resource object
Types ¶
This section is empty.
Source Files