kafka

Documentation

Index

• Constants
• func ClusterLocalEndpoint(namespace string) string
• func ConsumerNameForTopic(topic string) string
• func NewBrokerConfigMap(namespace string) *v1.ConfigMap
• func NewBrokerConfigMapFunctionalTestPod(namespace string) *v1.ConfigMap
• func NewBrokerRBAC(namespace string) (*rbacv1.ClusterRole, *rbacv1.ClusterRoleBinding)
• func NewBrokerSecret(namespace string) *v1.Secret
• func NewBrokerService(namespace string) *v1.Service
• func NewBrokerStatefuleSet(namespace string) *apps.StatefulSet
• func NewKafkaConsumerDeployment(namespace, topic string) *apps.Deployment
• func NewZookeeperConfigMap(namespace string) *v1.ConfigMap
• func NewZookeeperConfigMapFunctionalTestPod(namespace string) *v1.ConfigMap
• func NewZookeeperService(namespace string) *v1.Service
• func NewZookeeperStatefuleSet(namespace string) *apps.StatefulSet
• func TopicForInputName(topics []string, inputName string) string

Constants

const (
	DefaultTopic           = "clo-topic"
	AppLogsTopic           = "clo-app-topic"
	AuditLogsTopic         = "clo-audit-topic"
	InfraLogsTopic         = "clo-infra-topic"
	DeploymentName         = "kafka"
	ConsumerDeploymentName = "kafka-consumer"

	KafkaImage          = kafkaImageRepoOrg + "kafka:" + kafkaImageTag
	KafkaInitUtilsImage = kafkaImageRepoOrg + "kafka-initutils:" + kafkaImageTag
)

Functions

func ClusterLocalEndpoint

func ClusterLocalEndpoint(namespace string) string

func ConsumerNameForTopic

func ConsumerNameForTopic(topic string) string

func NewBrokerConfigMap

func NewBrokerConfigMap(namespace string) *v1.ConfigMap

func NewBrokerConfigMapFunctionalTestPod

func NewBrokerConfigMapFunctionalTestPod(namespace string) *v1.ConfigMap

func NewBrokerRBAC

func NewBrokerRBAC(namespace string) (*rbacv1.ClusterRole, *rbacv1.ClusterRoleBinding)

func NewBrokerSecret

func NewBrokerSecret(namespace string) *v1.Secret

func NewBrokerService

func NewBrokerService(namespace string) *v1.Service

func NewBrokerStatefuleSet

func NewBrokerStatefuleSet(namespace string) *apps.StatefulSet

func NewKafkaConsumerDeployment

func NewKafkaConsumerDeployment(namespace, topic string) *apps.Deployment

func NewZookeeperConfigMap

func NewZookeeperConfigMap(namespace string) *v1.ConfigMap

func NewZookeeperConfigMapFunctionalTestPod

func NewZookeeperConfigMapFunctionalTestPod(namespace string) *v1.ConfigMap

func NewZookeeperService

func NewZookeeperService(namespace string) *v1.Service

func NewZookeeperStatefuleSet

func NewZookeeperStatefuleSet(namespace string) *apps.StatefulSet

func TopicForInputName

func TopicForInputName(topics []string, inputName string) string