aiven_config

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 20, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

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 NewJavaConfig

func NewJavaConfig(secret *v1.Secret, destinationPath string) error

func WriteKCatConfigToFile

func WriteKCatConfigToFile(secret *v1.Secret, destinationPath string) error

func WriteKafkaEnvConfigToFile

func WriteKafkaEnvConfigToFile(secret *v1.Secret, destinationPath string) error

func WriteOpenSearchEnvConfigToFile

func WriteOpenSearchEnvConfigToFile(secret *v1.Secret, destinationPath string) error

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL