utils

Documentation

Index

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

Constants

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

	KafkaChannelSeparator = "."
)

Functions

func FindContainer

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

func TopicName

func TopicName(separator, namespace, name string) string

Types

type KafkaConfig

type KafkaConfig struct {
	Brokers       []string
	EventingKafka *config.EventingKafkaConfig
}

func GetKafkaConfig

func GetKafkaConfig(ctx context.Context, clientId string, configMap map[string]string, getAuth sarama.GetAuth) (*KafkaConfig, error)

GetKafkaConfig returns the details of the Kafka cluster.