Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateKafkaConsumer ¶
func CreateKafkaConsumer(triggerObjName, funcName, ns, topic string, clientset kubernetes.Interface) error
CreateKafkaConsumer creates a goroutine that subscribes to Kafka topic
func DeleteKafkaConsumer ¶
DeleteKafkaConsumer deletes goroutine created by CreateKafkaConsumer
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.