kafka

Documentation

Index

• Variables
• func GetKafka(c *providers.Provider) (providers.ClowderProvider, error)
• func NewAppInterface(p *providers.Provider) (providers.ClowderProvider, error)
• func NewMSK(p *providers.Provider) (providers.ClowderProvider, error)
• func NewManagedKafka(p *providers.Provider) (providers.ClowderProvider, error)
• func NewNoneKafka(p *providers.Provider) (providers.ClowderProvider, error)
• func NewStrimzi(p *providers.Provider) (providers.ClowderProvider, error)

Variables

var CyndiAppSecret = rc.NewSingleResourceIdent(ProvName, "cyndi_app_secret", &core.Secret{})

CyndiAppSecret identifies the cyndi app secret object.

var CyndiConfigMap = rc.NewSingleResourceIdent(ProvName, "cyndi_config_map", &core.ConfigMap{}, rc.ResourceOptions{WriteNow: true})

CyndiConfigMap is the resource ident for a CyndiConfigMap object.

var CyndiHostInventoryAppSecret = rc.NewSingleResourceIdent(ProvName, "cyndi_host_inventory_secret", &core.Secret{})

CyndiHostInventoryAppSecret identifies the cyndi host-inventory app secret object.

var CyndiPipeline = rc.NewSingleResourceIdent(ProvName, "cyndi_pipeline", &cyndi.CyndiPipeline{})

CyndiPipeline identifies the main cyndi pipeline object.

var DefaultImageKafkaXjoin = "quay.io/cloudservices/xjoin-kafka-connect-strimzi:latest"

var KafkaConnect = rc.NewSingleResourceIdent(ProvName, "kafka_connect", &strimzi.KafkaConnect{}, rc.ResourceOptions{WriteNow: true})

KafkaConnect is the resource ident for a KafkaConnect object.

var KafkaConnectSecret = rc.NewMultiResourceIdent(ProvName, "kafka_connect_secret", &core.Secret{})

KafkaConnectSecret is the resource ident for a MSK Connect secret object.

var KafkaConnectUser = rc.NewSingleResourceIdent(ProvName, "kafka_connect_user", &strimzi.KafkaUser{}, rc.ResourceOptions{WriteNow: true})

KafkaUser is the resource ident for a KafkaUser object.

var KafkaInstance = rc.NewSingleResourceIdent(ProvName, "kafka_instance", &strimzi.Kafka{}, rc.ResourceOptions{WriteNow: true})

KafkaInstance is the resource ident for a Kafka object.

var KafkaManagedSecret = rc.NewMultiResourceIdent(ProvName, "kafka_managed_secret", &core.Secret{})

KafkaManagedSecret is the resource ident for the MSK user secret object.

var KafkaMetricsConfigMap = rc.NewSingleResourceIdent(ProvName, "kafka_metrics_config_map", &core.ConfigMap{}, rc.ResourceOptions{WriteNow: true})

KafkaMetricsConfigMap is the resource ident for a KafkaMetricsConfigMap object.

var KafkaNetworkPolicy = rc.NewSingleResourceIdent(ProvName, "kafka_network_policy", &networking.NetworkPolicy{}, rc.ResourceOptions{WriteNow: true})

KafkaNetworkPolicy is the resource ident for the KafkaNetworkPolicy

var KafkaTopic = rc.NewSingleResourceIdent(ProvName, "kafka_topic", &strimzi.KafkaTopic{}, rc.ResourceOptions{WriteNow: true})

KafkaTopic is the resource ident for a KafkaTopic object.

var KafkaUser = rc.NewSingleResourceIdent(ProvName, "kafka_user", &strimzi.KafkaUser{}, rc.ResourceOptions{WriteNow: true})

KafkaUser is the resource ident for a KafkaUser object.

var ProvName = "kafka"

ProvName is the name/ident of the provider

Functions

func GetKafka

func GetKafka(c *providers.Provider) (providers.ClowderProvider, error)

GetKafka returns the correct kafka provider based on the environment.

func NewAppInterface

func NewAppInterface(p *providers.Provider) (providers.ClowderProvider, error)

NewAppInterface returns a new app-interface kafka provider object.

func NewMSK

func NewMSK(p *providers.Provider) (providers.ClowderProvider, error)

NewStrimzi returns a new strimzi provider object.

func NewManagedKafka

func NewManagedKafka(p *providers.Provider) (providers.ClowderProvider, error)

NewNoneKafka returns a new non kafka provider object.

func NewNoneKafka

func NewNoneKafka(p *providers.Provider) (providers.ClowderProvider, error)

NewNoneKafka returns a new non kafka provider object.

func NewStrimzi

func NewStrimzi(p *providers.Provider) (providers.ClowderProvider, error)

NewStrimzi returns a new strimzi provider object.