kafkasql

Documentation

Index

• func DeployKafkaCluster(suiteCtx *types.SuiteContext, req *CreateKafkaClusterRequest) *types.KafkaClusterInfo
• func DeployKafkaClusterV2(suiteCtx *types.SuiteContext, namespace string, replicas int, ...) *types.KafkaClusterInfo
• func DeployKafkaConnect(suiteCtx *types.SuiteContext, kafkaClusterInfo *types.KafkaClusterInfo, ...)
• func DeploySharedKafkaIfNeeded(suiteCtx *types.SuiteContext, ctx *types.TestContext) *types.KafkaClusterInfo
• func KafkaSqlDeployResource(suiteCtx *types.SuiteContext, ctx *types.TestContext) *apicurio.ApicurioRegistry
• func RemoveKafkaCluster(clientset *kubernetes.Clientset, namespace string, ...)
• func RemoveKafkaConnect(suiteCtx *types.SuiteContext, kafkaClusterInfo *types.KafkaClusterInfo)
• func RemoveKafkaSqlRegistry(suiteCtx *types.SuiteContext, ctx *types.TestContext)
• func RemoveSharedKafkaIfNeeded(suiteCtx *types.SuiteContext, ctx *types.TestContext, ...)
• func RemoveStrimziOperator(clientset *kubernetes.Clientset, namespace string)
• type CreateKafkaClusterRequest

Functions

func DeployKafkaCluster

func DeployKafkaCluster(suiteCtx *types.SuiteContext, req *CreateKafkaClusterRequest) *types.KafkaClusterInfo

func DeployKafkaClusterV2

func DeployKafkaClusterV2(suiteCtx *types.SuiteContext, namespace string, replicas int, exposeExternal bool, name string, topics []string) *types.KafkaClusterInfo

DeployKafkaCluster deploys a kafka cluster and some topics, returns a flag to indicate if strimzi operator has been deployed(useful to know if it was already installed)

func DeployKafkaConnect

func DeployKafkaConnect(suiteCtx *types.SuiteContext, kafkaClusterInfo *types.KafkaClusterInfo, image string, convertersPlugin types.KafkaConnectPlugin)

func DeploySharedKafkaIfNeeded

func DeploySharedKafkaIfNeeded(suiteCtx *types.SuiteContext, ctx *types.TestContext) *types.KafkaClusterInfo

func KafkaSqlDeployResource

func KafkaSqlDeployResource(suiteCtx *types.SuiteContext, ctx *types.TestContext) *apicurio.ApicurioRegistry

func RemoveKafkaCluster

func RemoveKafkaCluster(clientset *kubernetes.Clientset, namespace string, kafkaClusterInfo *types.KafkaClusterInfo)

RemoveKafkaCluster removes a kafka cluster

func RemoveKafkaConnect

func RemoveKafkaConnect(suiteCtx *types.SuiteContext, kafkaClusterInfo *types.KafkaClusterInfo)

func RemoveKafkaSqlRegistry

func RemoveKafkaSqlRegistry(suiteCtx *types.SuiteContext, ctx *types.TestContext)

RemoveKafkaSqlRegistry uninstalls registry CR, kafka cluster and strimzi operator

func RemoveSharedKafkaIfNeeded

func RemoveSharedKafkaIfNeeded(suiteCtx *types.SuiteContext, ctx *types.TestContext, kafkaCluster *types.KafkaClusterInfo)

func RemoveStrimziOperator

func RemoveStrimziOperator(clientset *kubernetes.Clientset, namespace string)

RemoveStrimziOperator uninstalls strimzi operator

Types

type CreateKafkaClusterRequest

type CreateKafkaClusterRequest struct {
	Namespace      string
	Replicas       int
	ExposeExternal bool
	Name           string
	Topics         []string
	Security       string
}