utils

Documentation

Index

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

Constants

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

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

	KafkaChannelSeparator = "."

	// DefaultNumPartitions defines the default number of partitions
	DefaultNumPartitions = 1

	// DefaultReplicationFactor defines the default number of replications
	DefaultReplicationFactor = 1

	DefaultMaxIdleConns        = 1000
	DefaultMaxIdleConnsPerHost = 100
)

Functions

func FindContainer

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

func TopicName

func TopicName(separator, namespace, name string) string

Types

type KafkaAuthConfig

type KafkaAuthConfig struct {
	TLS  *KafkaTlsConfig
	SASL *KafkaSaslConfig
}

func GetKafkaAuthData

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

type KafkaConfig

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

func GetKafkaConfig

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

GetKafkaConfig returns the details of the Kafka cluster.

type KafkaSaslConfig

type KafkaSaslConfig struct {
	User     string
	Password string
	SaslType string
}

type KafkaTlsConfig

type KafkaTlsConfig struct {
	Cacert   string
	Usercert string
	Userkey  string
}