Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateKinesisStreamConsumer ¶
func CreateKinesisStreamConsumer(triggerObj *kinesisApi.KinesisTrigger, funcName, ns string, clientset kubernetes.Interface) error
CreateKinesisStreamConsumer creates a goroutine that polls the Kinesis stream for new records and forwards the data to function
func DeleteKinesisConsumer ¶
func DeleteKinesisConsumer(triggerObj *kinesisApi.KinesisTrigger, funcName, ns string) error
DeleteKinesisConsumer deletes goroutine created by CreateNATSConsumer
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.