pkg

package
v0.41.1 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 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"
	SaslRestrictedUserSecretName = "my-restricted-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.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.