The highest tagged major version is v5.

testutil

package

v1.24.0 Latest Latest Go to latest Published: Dec 3, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var RootDir string

func AssertContains(t *testing.T, expected string, array []string)

func AssertContainsNot(t *testing.T, unexpected string, array []string)

func AssertEquals(t *testing.T, expected, actual string)

func AssertErrorContains(t *testing.T, expected string, err error)

func AssertErrorContainsOneOf(t *testing.T, expected []string, err error)

func CreateAvroTopic(t *testing.T, topicPrefix, keySchema, valueSchema string, flags ...string) string

func CreateClient(t *testing.T) sarama.Client

func CreateConsumerGroup(t *testing.T, topic string, groupPrefix string) string

func CreateTopic(t *testing.T, topicPrefix string, flags ...string) string

func GetPrefixedName(prefix string) string

func MarkOffset(t *testing.T, client sarama.Client, groupName string, topic string, partition int32, offset int64)

func StartIntegrationTest(t *testing.T)

func StartIntegrationTestWithContext(t *testing.T, context string)

func StartUnitTest(t *testing.T)

func SwitchContext(context string)

func VerifyGroupExists(t *testing.T, group string)

func VerifyTopicExists(t *testing.T, topic string)

func WithoutBrokerReferences(output string) string

type KafkaCtlTestCommand struct {
	Streams output.IOStreams
	Root    *cobra.Command
	Verbose bool
}

func CreateKafkaCtlCommand() (kafkactl KafkaCtlTestCommand)

func (kafkactl *KafkaCtlTestCommand) Execute(args ...string) (cmd *cobra.Command, err error)

func (kafkactl *KafkaCtlTestCommand) GetStdErr() string

func (kafkactl *KafkaCtlTestCommand) GetStdOut() string