testing

Documentation

Index

• Constants
• Variables
• func LogJobOutput(t *testing.T, ctx context.Context, c kubernetes.Interface, namespace string, ...)
• func Plaintext(t *testing.T, _ *testlib.Client) map[string][]byte
• func RunMultiple(t *testing.T, f func(t *testing.T))
• func RunMultipleN(t *testing.T, n int, f func(t *testing.T))
• func SaslPlaintextScram512(t *testing.T, client *testlib.Client) map[string][]byte
• func Ssl(t *testing.T, client *testlib.Client) map[string][]byte
• func SslSaslScram512(t *testing.T, client *testlib.Client) map[string][]byte
• type ConfigProvider
• type SecretProvider

Constants

const (

	// Kafka bootstrap server.
	BootstrapServersPlaintext     = "my-cluster-kafka-bootstrap.kafka:9092"
	BootstrapServersSsl           = "my-cluster-kafka-bootstrap.kafka:9093"
	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

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

Functions

func LogJobOutput

func LogJobOutput(t *testing.T, ctx context.Context, c kubernetes.Interface, namespace string, app string)

func Plaintext

func Plaintext(t *testing.T, _ *testlib.Client) map[string][]byte

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.

func SaslPlaintextScram512

func SaslPlaintextScram512(t *testing.T, client *testlib.Client) map[string][]byte

func Ssl

func Ssl(t *testing.T, client *testlib.Client) map[string][]byte

func SslSaslScram512

func SslSaslScram512(t *testing.T, client *testlib.Client) map[string][]byte

Types

type ConfigProvider

type ConfigProvider func(secretName string, client *testlib.Client) map[string]string

type SecretProvider

type SecretProvider func(t *testing.T, client *testlib.Client) map[string][]byte