util

Documentation

Index

• func GetKafkaSecrets(ctx context.Context, k8sClient kubernetes.Interface, k8sNamespace string) (*corev1.SecretList, error)
• func NewTopicError(kError sarama.KError, message string) *sarama.TopicError
• func NewUnknownTopicError(message string) *sarama.TopicError
• func PromoteErrorToTopicError(err error) *sarama.TopicError
• func ValidateKafkaSecret(logger *zap.Logger, secret *corev1.Secret) bool

Functions

func GetKafkaSecrets

func GetKafkaSecrets(ctx context.Context, k8sClient kubernetes.Interface, k8sNamespace string) (*corev1.SecretList, error)

Utility Function For Getting All (Limit 100) The Kafka Secrets In A K8S Namespace

func NewTopicError

func NewTopicError(kError sarama.KError, message string) *sarama.TopicError

Utility Function For Creating A Sarama TopicError With Specified Kafka Error Code (ErrNoError == Success)

func NewUnknownTopicError

func NewUnknownTopicError(message string) *sarama.TopicError

Utility Function For Creating A New ErrUnknownTopicError With Specified Message

func PromoteErrorToTopicError

func PromoteErrorToTopicError(err error) *sarama.TopicError

Utility Function To Up-Convert Any Basic Errors Into TopicErrors

func ValidateKafkaSecret

func ValidateKafkaSecret(logger *zap.Logger, secret *corev1.Secret) bool

Utility Function For Validating Kafka Secret