bustest

package

v0.7.1 Latest Latest Go to latest Published: Nov 13, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func Docker(t testing.TB) *dockertest.Pool

func RegisterServer(name string, fnc ServerFunc)

func TestAll(t *testing.T, test func(t *testing.T, bus func(t testing.TB) bus.MessageBus))

type Server interface {
	Connect(t testing.TB) bus.MessageBus
}

func NewLocalBus() Server

func NewNATS(t testing.TB, pool *dockertest.Pool) Server

func NewRedis(t testing.TB, pool *dockertest.Pool) Server

type ServerFunc func(t testing.TB, pool *dockertest.Pool) Server