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 = rc.NewSingleResourceIdent(ProvName, "cyndi_app_secret", &core.Secret{})

CyndiAppSecret identifies the cyndi app secret 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 KafkaConnect = rc.NewSingleResourceIdent(ProvName, "kafka_connect", &strimzi.KafkaConnect{}, rc.ResourceOptions{WriteNow: true})

KafkaConnect is the resource ident for a KafkaConnect 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 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 LocalKafkaDeployment = rc.NewSingleResourceIdent(ProvName, "local_kafka_deployment", &apps.Deployment{})

LocalKafkaDeployment identifies the main kafka deployment

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

LocalKafkaPVC identifies the main kafka configmap

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

LocalKafkaService identifies the main kafka service

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

LocalZookeeperDeployment identifies the main zookeeper deployment

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

LocalZookeeperPVC identifies the main zookeeper configmap

var LocalZookeeperService = rc.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.