Documentation
¶
Index ¶
- Constants
- func NewJavaConfig(secret *v1.Secret, destinationPath string) error
- func WriteKCatConfigToFile(secret *v1.Secret, destinationPath string) error
- func WriteKafkaEnvConfigToFile(secret *v1.Secret, destinationPath string) error
- func WriteOpenSearchEnvConfigToFile(secret *v1.Secret, destinationPath string) error
Constants ¶
View Source
const ( KafkaCertificateCrtFile = "kafka-certificate.crt" KafkaPrivateKeyPemFile = "kafka-private-key.pem" KafkaCACrtFile = "kafka-ca.pem" KafkaClientKeyStoreP12File = "client.keystore.p12" KafkaClientTruststoreJksFile = "client.truststore.jks" KafkaCertificatePathKey = "KAFKA_CERTIFICATE_PATH" KafkaPrivateKeyPathKey = "KAFKA_PRIVATE_KEY_PATH" KafkaCAPathKey = "KAFKA_CA_PATH" KafkaKeystorePathKey = "KAFKA_KEYSTORE_PATH" KafkaTruststorePathKey = "KAFKA_TRUSTSTORE_PATH" KafkaCertificateKey = "KAFKA_CERTIFICATE" KafkaPrivateKeyKey = "KAFKA_PRIVATE_KEY" KafkaCAKey = "KAFKA_CA" KafkaBrokersKey = "KAFKA_BROKERS" KafkaSchemaRegistryKey = "KAFKA_SCHEMA_REGISTRY" KafkaSchemaRegistryPasswordKey = "KAFKA_SCHEMA_REGISTRY_PASSWORD" KafkaSchemaRegistryUserKey = "KAFKA_SCHEMA_REGISTRY_USER" KafkaCredStorePasswordKey = "KAFKA_CREDSTORE_PASSWORD" FilePermission = 0o775 )
View Source
const ( KafkaEnvName = "kafka-secret.env" OpenSearchEnvName = "opensearch-secret.env" OpenSearchHostKey = "OPEN_SEARCH_HOST" OpenSearchURIKey = "OPEN_SEARCH_URI" OpenSearchUsernameKey = "OPEN_SEARCH_USERNAME" OpenSearchPasswordKey = "OPEN_SEARCH_PASSWORD" )
View Source
const ( KafkaJavaConfigName = "kafka.properties" KeyPassProp = "ssl.key.password" KeyStorePassProp = "ssl.keystore.password" TrustStorePassProp = "ssl.truststore.password" KeyStoreLocationProp = "ssl.keystore.location" TrustStoreLocationProp = "ssl.truststore.location" FileHeader = `` /* 196-byte string literal not displayed */ )
View Source
const ( KafkaCatSslCertificateLocation = "ssl.certificate.location" KafkaCatSslKeyLocation = "ssl.key.location" KafkaCatSslCaLocation = "ssl.ca.location" KafkaCatBootstrapServers = "bootstrap.servers" KafkaSecurityProtocolLocation = "security.protocol" KafkaCatConfigName = "kcat.conf" )
Variables ¶
This section is empty.
Functions ¶
func WriteKCatConfigToFile ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.