Documentation
¶
Index ¶
- Variables
- func CreateKafkaConsumer(triggerObjName, funcName, ns, topic string, clientset kubernetes.Interface) error
- func DeleteKafkaConsumer(triggerObjName, funcName, ns, topic string) error
- func GetSASLConfiguration(username string, password string) (string, string, error)
- func GetTLSConfiguration(caFile string, certFile string, keyFile string, insecure string) (*tls.Config, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrorCrtFileMandatory when private key is provided but certificate not. ErrorCrtFileMandatory = errors.New("client certificate is mandatory when private key file is provided") // ErrorKeyFileMandatory when certificate is provided but private not. ErrorKeyFileMandatory = errors.New("client private key is mandatory when certificate file is provided") // ErrorUsernameOrPasswordMandatory when username or password is not provided ErrorUsernameOrPasswordMandatory = errors.New("username and password is mandatory") )
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
func GetSASLConfiguration ¶
GetSASLConfiguration build SASL configuration for kafka.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.