bustest

package

v0.7.6 Latest Latest Go to latest Published: Sep 5, 2026 License: Apache-2.0 Imports: 12 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 Connect))

type Connect func(t testing.TB, opts ...bus.BusOption) bus.MessageBus

type Server interface {
	Connect(t testing.TB, opts ...bus.BusOption) 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