test_helpers

Documentation

Index

• type TestContext
  • func NewTestContext() *TestContext
  • func (ts *TestContext) ChangeAndReadOne(query string, kafkaTopic string) (*mysql.Result, *kafka.Message, error)
  • func (ts *TestContext) GetAllKafkaBrokers() []string
  • func (ts *TestContext) GetDBAddr() string

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