test_helpers

package
v0.0.0-...-db03bc8 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type TestContext

type TestContext struct {
	MysqlPort  int
	ZK1Port    int
	ZK2Port    int
	Kafka1Port int
	Kafka2Port int
	Kafka3Port int

	DBUser string
	DBPass string

	SeedPath string
	TestUUID string

	ComposePath string
	Compose     *tc.LocalDockerCompose
}

func NewTestContext

func NewTestContext() *TestContext

func (*TestContext) ChangeAndReadOne

func (ts *TestContext) ChangeAndReadOne(query string, kafkaTopic string) (*mysql.Result, *kafka.Message, error)

func (*TestContext) GetAllKafkaBrokers

func (ts *TestContext) GetAllKafkaBrokers() []string

func (*TestContext) GetDBAddr

func (ts *TestContext) GetDBAddr() string

Jump to

Keyboard shortcuts

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