sidecars

Documentation

Index

• func InsprAppIDConfig(app *meta.App) k8s.ContainerOption
• func KafkaEnvConfig(config KafkaConfig) k8s.ContainerOption
• func KafkaSidecarConfig(config KafkaConfig, conns *models.SidecarConnections) (k8s.ContainerOption, []corev1.EnvVar)
• func KafkaToDeployment(config KafkaConfig) models.SidecarFactory
• type KafkaConfig
  • func (kc KafkaConfig) Broker() string

Functions

func InsprAppIDConfig

func InsprAppIDConfig(app *meta.App) k8s.ContainerOption

InsprAppIDConfig adds the dapp id that the sidecar is related to

func KafkaEnvConfig

func KafkaEnvConfig(config KafkaConfig) k8s.ContainerOption

KafkaEnvConfig adds the necessary env variables to configure kafka

func KafkaSidecarConfig

func KafkaSidecarConfig(config KafkaConfig, conns *models.SidecarConnections) (k8s.ContainerOption, []corev1.EnvVar)

KafkaSidecarConfig adds the necessary env variables to configure the sidecar in the cluster

func KafkaToDeployment

func KafkaToDeployment(config KafkaConfig) models.SidecarFactory

KafkaToDeployment receives a the KafkaConfig variable as a parameter and returns a SidecarFactory function that is used to subscribe to the sidecarFactory

Types

type KafkaConfig

type KafkaConfig struct {
	BootstrapServers string `yaml:"bootstrapServers"`
	AutoOffsetReset  string `yaml:"autoOffsetReset"`
	SidecarImage     string `yaml:"sidecarImage"`
	// KafkaInsprAddr is the port used in the insprd service of your cluster
	KafkaInsprAddr string `yaml:"sidecarAddr"`
}

KafkaConfig configurations used to create the KafkaSidecar

func (KafkaConfig) Broker

func (kc KafkaConfig) Broker() string

Broker is a BrokerConfiguration interface method, it returns the broker name for this config type