kafka

Documentation

Index

• Variables
• func GetKafka(c *providers.Provider) (providers.ClowderProvider, error)
• func NewAppInterface(p *providers.Provider) (providers.ClowderProvider, error)
• func NewLocalKafka(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 = providers.NewSingleResourceIdent(ProvName, "cyndi_app_secret", &core.Secret{})

CyndiAppSecret identifies the cyndi app secret object.

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

CyndiHostInventoryAppSecret identifies the cyndi host-inventory app secret object.

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

CyndiPipeline identifies the main cyndi pipeline object.

var KafkaConnect = providers.NewSingleResourceIdent(ProvName, "kafka_connect", &strimzi.KafkaConnect{})

KafkaConnect is the resource ident for a KafkaConnect object.

var KafkaConnectUser = providers.NewSingleResourceIdent(ProvName, "kafka_connect_user", &strimzi.KafkaUser{})

KafkaUser is the resource ident for a KafkaUser object.

var KafkaInstance = providers.NewSingleResourceIdent(ProvName, "kafka_instance", &strimzi.Kafka{})

KafkaInstance is the resource ident for a Kafka object.

var KafkaMetricsConfigMap = providers.NewSingleResourceIdent(ProvName, "kafka_metrics_config_map", &core.ConfigMap{})

KafkaMetricsConfigMap is the resource ident for a KafkaMetricsConfigMap object.

var KafkaNetworkPolicy = providers.NewSingleResourceIdent(ProvName, "kafka_network_policy", &networking.NetworkPolicy{})

KafkaNetworkPolicy is the resource ident for the KafkaNetworkPolicy

var KafkaTopic = providers.NewSingleResourceIdent(ProvName, "kafka_topic", &strimzi.KafkaTopic{})

KafkaTopic is the resource ident for a KafkaTopic object.

var KafkaUser = providers.NewSingleResourceIdent(ProvName, "kafka_user", &strimzi.KafkaUser{})

KafkaUser is the resource ident for a KafkaUser object.

var LocalKafkaDeployment = providers.NewSingleResourceIdent(ProvName, "local_kafka_deployment", &apps.Deployment{})

LocalKafkaDeployment identifies the main kafka deployment

var LocalKafkaPVC = providers.NewSingleResourceIdent(ProvName, "local_kafka_pvc", &core.PersistentVolumeClaim{})

LocalKafkaPVC identifies the main kafka configmap

var LocalKafkaService = providers.NewSingleResourceIdent(ProvName, "local_kafka_service", &core.Service{})

LocalKafkaService identifies the main kafka service

var LocalZookeeperDeployment = providers.NewSingleResourceIdent(ProvName, "local_zookeeper_deployment", &apps.Deployment{})

LocalZookeeperDeployment identifies the main zookeeper deployment

var LocalZookeeperPVC = providers.NewSingleResourceIdent(ProvName, "local_zookeeper_pvc", &core.PersistentVolumeClaim{})

LocalZookeeperPVC identifies the main zookeeper configmap

var LocalZookeeperService = providers.NewSingleResourceIdent(ProvName, "local_zookeeper_service", &core.Service{})

LocalZookeeperService identifies the main zookeeper service

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 NewLocalKafka

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

NewLocalKafka returns a new local kafka 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.