utils

Documentation

Index

• Constants
• func FindContainer(d *appsv1.Deployment, containerName string) *corev1.Container
• func GetKafkaAuthData(ctx context.Context, secretname string, secretNS string) *client.KafkaAuthConfig
• func TopicName(separator, namespace, name string) string
• type KafkaConfig
  • func GetKafkaConfig(configMap map[string]string) (*KafkaConfig, error)

Constants

const (
	BrokerConfigMapKey           = "bootstrapServers"
	AuthSecretName               = "authSecretName"
	AuthSecretNamespace          = "authSecretNamespace"
	MaxIdleConnectionsKey        = "maxIdleConns"
	MaxIdleConnectionsPerHostKey = "maxIdleConnsPerHost"

	TlsEnabled   = "tls.enabled"
	TlsCacert    = "ca.crt"
	TlsUsercert  = "user.crt"
	TlsUserkey   = "user.key"
	SaslUser     = "user"
	SaslPassword = "password"
	SaslType     = "saslType"

	KafkaChannelSeparator = "."
)

Functions

func FindContainer

func FindContainer(d *appsv1.Deployment, containerName string) *corev1.Container

func GetKafkaAuthData

func GetKafkaAuthData(ctx context.Context, secretname string, secretNS string) *client.KafkaAuthConfig

func TopicName

func TopicName(separator, namespace, name string) string

Types

type KafkaConfig

type KafkaConfig struct {
	Brokers                  []string
	MaxIdleConns             int32
	MaxIdleConnsPerHost      int32
	AuthSecretName           string
	AuthSecretNamespace      string
	SaramaSettingsYamlString string
}

func GetKafkaConfig

func GetKafkaConfig(configMap map[string]string) (*KafkaConfig, error)

GetKafkaConfig returns the details of the Kafka cluster.