pkg

Documentation

Index

• Constants
• Variables
• func RunMultiple(t *testing.T, f func(t *testing.T))
• func RunMultipleN(t *testing.T, n int, f func(t *testing.T))

Constants

const (

	// Kafka bootstrap server.
	BootstrapServersPlaintext     = "my-cluster-kafka-bootstrap.kafka:9092"
	BootstrapServersSsl           = "my-cluster-kafka-bootstrap.kafka:9093"
	BootstrapServersTlsNoAuth     = "my-cluster-kafka-bootstrap.kafka:9096"
	BootstrapServersSaslPlaintext = "my-cluster-kafka-bootstrap.kafka:9095"
	BootstrapServersSslSaslScram  = "my-cluster-kafka-bootstrap.kafka:9094"

	NumPartitions     = 10
	ReplicationFactor = 3

	KafkaClusterNamespace        = "kafka"
	TlsUserSecretName            = "my-tls-user"
	SaslUserSecretName           = "my-sasl-user"
	SaslRestrictedUserSecretName = "my-restricted-sasl-user"
	CaSecretName                 = "my-cluster-cluster-ca-cert"
)

Variables

var (
	// Kafka bootstrap server as array.
	BootstrapServersPlaintextArr     = []string{BootstrapServersPlaintext}
	BootstrapServersSslArr           = []string{BootstrapServersSsl}
	BootstrapServersTlsNoAuthArr     = []string{BootstrapServersTlsNoAuth}
	BootstrapServersSaslPlaintextArr = []string{BootstrapServersSaslPlaintext}
	BootstrapServersSslSaslScramArr  = []string{BootstrapServersSslSaslScram}
)

Functions

func RunMultiple

func RunMultiple(t *testing.T, f func(t *testing.T))

RunMultiple run test function f `rerunTimes` times.

func RunMultipleN

func RunMultipleN(t *testing.T, n int, f func(t *testing.T))

RunMultiple run test function f n times.