Documentation ¶
Index ¶
Constants ¶
View Source
const ( KafkaBrokers = "KAFKA_BROKERS" KafkaSchemaRegistry = "KAFKA_SCHEMA_REGISTRY" KafkaSchemaUser = "KAFKA_SCHEMA_REGISTRY_USER" KafkaSchemaPassword = "KAFKA_SCHEMA_REGISTRY_PASSWORD" KafkaCertificate = "KAFKA_CERTIFICATE" KafkaPrivateKey = "KAFKA_PRIVATE_KEY" KafkaCA = "KAFKA_CA" KafkaCredStorePassword = "KAFKA_CREDSTORE_PASSWORD" KafkaSecretUpdated = "KAFKA_SECRET_UPDATED" KafkaKeystore = "client.keystore.p12" KafkaTruststore = "client.truststore.jks" )
Keys in secret
View Source
const ( ServiceUserAnnotation = "kafka.aiven.nais.io/serviceUser" PoolAnnotation = "kafka.aiven.nais.io/pool" )
Annotations
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaHandler ¶
type KafkaHandler struct {
// contains filtered or unexported fields
}
func NewKafkaHandler ¶
func (KafkaHandler) Apply ¶
func (h KafkaHandler) Apply(ctx context.Context, application *aiven_nais_io_v1.AivenApplication, secret *v1.Secret, logger log.FieldLogger) error
func (*KafkaHandler) StartUserCounter ¶
func (h *KafkaHandler) StartUserCounter(ctx context.Context, logger *log.Entry)
Click to show internal directories.
Click to hide internal directories.