Documentation ¶
Index ¶
- Constants
- func NewKafkasqlCF(ctx context.LoopContext) loop.ControlFunction
- func NewKafkasqlSecurityScramCF(ctx context.LoopContext) loop.ControlFunction
- func NewKafkasqlSecurityTLSCF(ctx context.LoopContext) loop.ControlFunction
- type KafkasqlCF
- type KafkasqlSecurityScramCF
- func (this *KafkasqlSecurityScramCF) AddEnv(truststoreSecretName string, truststoreSecretVolumeName string, ...)
- func (this *KafkasqlSecurityScramCF) AddSecretMountPatch(deploymentEntry resources.ResourceCacheEntry, volumeName string, ...)
- func (this *KafkasqlSecurityScramCF) AddSecretVolumePatch(deploymentEntry resources.ResourceCacheEntry, secretName string, ...)
- func (this *KafkasqlSecurityScramCF) Cleanup() bool
- func (this *KafkasqlSecurityScramCF) Compare() bool
- func (this *KafkasqlSecurityScramCF) Describe() string
- func (this *KafkasqlSecurityScramCF) Respond()
- func (this *KafkasqlSecurityScramCF) Sense()
- type KafkasqlSecurityTLSCF
- func (this *KafkasqlSecurityTLSCF) AddEnv(keystoreSecretName string, keystoreSecretVolumeName string, ...)
- func (this *KafkasqlSecurityTLSCF) AddSecretMountPatch(deploymentEntry resources.ResourceCacheEntry, volumeName string, ...)
- func (this *KafkasqlSecurityTLSCF) AddSecretVolumePatch(deploymentEntry resources.ResourceCacheEntry, secretName string, ...)
- func (this *KafkasqlSecurityTLSCF) Cleanup() bool
- func (this *KafkasqlSecurityTLSCF) Compare() bool
- func (this *KafkasqlSecurityTLSCF) Describe() string
- func (this *KafkasqlSecurityTLSCF) Respond()
- func (this *KafkasqlSecurityTLSCF) Sense()
Constants ¶
View Source
const ( PERSISTENCE_ID = "kafkasql" ENV_KAFKA_BOOTSTRAP_SERVERS = "KAFKA_BOOTSTRAP_SERVERS" )
View Source
const ENV_REGISTRY_KAFKASQL_SCRAM_PASSWORD = "REGISTRY_KAFKASQL_SCRAM_PASSWORD"
View Source
const ENV_REGISTRY_KAFKASQL_SCRAM_USER = "REGISTRY_KAFKASQL_SCRAM_USER"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SASL_JAAS_CONFIG = "REGISTRY_KAFKA_COMMON_SASL_JAAS_CONFIG"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SASL_MECHANISM = "REGISTRY_KAFKA_COMMON_SASL_MECHANISM"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SECURITY_PROTOCOL = "REGISTRY_KAFKA_COMMON_SECURITY_PROTOCOL"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SSL_KEYSTORE_LOCATION = "REGISTRY_KAFKA_COMMON_SSL_KEYSTORE_LOCATION"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SSL_KEYSTORE_PASSWORD = "REGISTRY_KAFKA_COMMON_SSL_KEYSTORE_PASSWORD"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SSL_KEYSTORE_TYPE = "REGISTRY_KAFKA_COMMON_SSL_KEYSTORE_TYPE"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SSL_TRUSTSTORE_LOCATION = "REGISTRY_KAFKA_COMMON_SSL_TRUSTSTORE_LOCATION"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SSL_TRUSTSTORE_PASSWORD = "REGISTRY_KAFKA_COMMON_SSL_TRUSTSTORE_PASSWORD"
View Source
const ENV_REGISTRY_KAFKA_COMMON_SSL_TRUSTSTORE_TYPE = "REGISTRY_KAFKA_COMMON_SSL_TRUSTSTORE_TYPE"
View Source
const ENV_REGISTRY_PROPERTIES_PREFIX = "REGISTRY_PROPERTIES_PREFIX"
View Source
const KEYSTORE_SECRET_VOLUME_NAME = "registry-kafkasql-tls-keystore"
View Source
const SCRAM_TRUSTSTORE_SECRET_VOLUME_NAME = "registry-kafkasql-scram-truststore"
View Source
const TRUSTSTORE_SECRET_VOLUME_NAME = "registry-kafkasql-tls-truststore"
Variables ¶
This section is empty.
Functions ¶
func NewKafkasqlCF ¶
func NewKafkasqlCF(ctx context.LoopContext) loop.ControlFunction
func NewKafkasqlSecurityScramCF ¶
func NewKafkasqlSecurityScramCF(ctx context.LoopContext) loop.ControlFunction
func NewKafkasqlSecurityTLSCF ¶
func NewKafkasqlSecurityTLSCF(ctx context.LoopContext) loop.ControlFunction
Types ¶
type KafkasqlCF ¶
type KafkasqlCF struct {
// contains filtered or unexported fields
}
func (*KafkasqlCF) Cleanup ¶
func (this *KafkasqlCF) Cleanup() bool
func (*KafkasqlCF) Compare ¶
func (this *KafkasqlCF) Compare() bool
func (*KafkasqlCF) Describe ¶
func (this *KafkasqlCF) Describe() string
func (*KafkasqlCF) Respond ¶
func (this *KafkasqlCF) Respond()
func (*KafkasqlCF) Sense ¶
func (this *KafkasqlCF) Sense()
type KafkasqlSecurityScramCF ¶
type KafkasqlSecurityScramCF struct {
// contains filtered or unexported fields
}
func (*KafkasqlSecurityScramCF) AddSecretMountPatch ¶
func (this *KafkasqlSecurityScramCF) AddSecretMountPatch(deploymentEntry resources.ResourceCacheEntry, volumeName string, mountPath string)
func (*KafkasqlSecurityScramCF) AddSecretVolumePatch ¶
func (this *KafkasqlSecurityScramCF) AddSecretVolumePatch(deploymentEntry resources.ResourceCacheEntry, secretName string, volumeName string)
func (*KafkasqlSecurityScramCF) Cleanup ¶
func (this *KafkasqlSecurityScramCF) Cleanup() bool
func (*KafkasqlSecurityScramCF) Compare ¶
func (this *KafkasqlSecurityScramCF) Compare() bool
func (*KafkasqlSecurityScramCF) Describe ¶
func (this *KafkasqlSecurityScramCF) Describe() string
func (*KafkasqlSecurityScramCF) Respond ¶
func (this *KafkasqlSecurityScramCF) Respond()
func (*KafkasqlSecurityScramCF) Sense ¶
func (this *KafkasqlSecurityScramCF) Sense()
type KafkasqlSecurityTLSCF ¶
type KafkasqlSecurityTLSCF struct {
// contains filtered or unexported fields
}
func (*KafkasqlSecurityTLSCF) AddEnv ¶
func (this *KafkasqlSecurityTLSCF) AddEnv(keystoreSecretName string, keystoreSecretVolumeName string, truststoreSecretName string, truststoreSecretVolumeName string)
func (*KafkasqlSecurityTLSCF) AddSecretMountPatch ¶
func (this *KafkasqlSecurityTLSCF) AddSecretMountPatch(deploymentEntry resources.ResourceCacheEntry, volumeName string, mountPath string)
func (*KafkasqlSecurityTLSCF) AddSecretVolumePatch ¶
func (this *KafkasqlSecurityTLSCF) AddSecretVolumePatch(deploymentEntry resources.ResourceCacheEntry, secretName string, volumeName string)
func (*KafkasqlSecurityTLSCF) Cleanup ¶
func (this *KafkasqlSecurityTLSCF) Cleanup() bool
func (*KafkasqlSecurityTLSCF) Compare ¶
func (this *KafkasqlSecurityTLSCF) Compare() bool
func (*KafkasqlSecurityTLSCF) Describe ¶
func (this *KafkasqlSecurityTLSCF) Describe() string
func (*KafkasqlSecurityTLSCF) Respond ¶
func (this *KafkasqlSecurityTLSCF) Respond()
func (*KafkasqlSecurityTLSCF) Sense ¶
func (this *KafkasqlSecurityTLSCF) Sense()
Click to show internal directories.
Click to hide internal directories.