testcontainer_redpanda.go

type TestContainerWrapper struct {
	container testcontainers.Container
	hostPort  int
}

type IntegrationTestSuite struct {
	suite.Suite
	wrapper TestContainerWrapper
}

func (s *IntegrationTestSuite) SetupSuite() {
	if err := s.wrapper.RunContainer(); err != nil {
		log.Fatalln(err)
	}
}

func (s *IntegrationTestSuite) TearDownSuite() {
	s.wrapper.CleanUp()
}

func Test_By_Using_Testcontainers(t *testing.T) {
	if testing.Short() {
		t.Skip()
	}
	suite.Run(t, new(IntegrationTestSuite))
}

func (s *IntegrationTestSuite) Test_Should_Consume_Successfully() {
	// ...
}

func (s *IntegrationTestSuite) Test_Should_Produce_Successfully() {
	// ....
}