kafkasql

package

v1.1.2 Latest Latest Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Apicurio/apicurio-registry-operator

Links

Open Source Insights

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
type KafkasqlSecurityTLSCF

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) AddEnv ¶

func (this *KafkasqlSecurityScramCF) AddEnv(truststoreSecretName string, truststoreSecretVolumeName string,
	scramUser string, scramPasswordSecretName string, scramMechanism string)

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()

Source Files ¶

View all Source files

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