pkg

package
v0.38.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 2, 2023 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source
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"
	CaSecretName          = "my-cluster-cluster-ca-cert"
)

Variables

View Source
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.

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL