kafka-go: github.com/segmentio/kafka-go/testing Index | Files

package testing

import "github.com/segmentio/kafka-go/testing"

Index

Package Files

conn.go version.go

func KafkaIsAtLeast Uses

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.

type ConnWaitGroup Uses

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

func (*ConnWaitGroup) Dial Uses

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

Package testing imports 6 packages (graph). Updated 2021-01-21. Refresh now. Tools for package owners.