testing

package
v0.4.50 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func KafkaIsAtLeast

func KafkaIsAtLeast(semver string) bool

KafkaIsAtLeast returns true when the test broker is running a protocol version that is semver or newer. It determines the broker's version using the `KAFKA_VERSION` environment variable. If the var is unset, then this function will return true.

Types

type ConnWaitGroup added in v0.4.49

type ConnWaitGroup struct {
	DialFunc func(context.Context, string, string) (net.Conn, error)
	sync.WaitGroup
}

func (*ConnWaitGroup) Dial added in v0.4.49

func (g *ConnWaitGroup) Dial(ctx context.Context, network, address string) (net.Conn, error)

Jump to

Keyboard shortcuts

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