hack

func Check(t testing.TB)

func Context(t testing.TB) context.Context

func RunPulsarPubSubTestSuite(
	ctx context.Context,
	t testing.TB,
	dsn string,
	messages []ProducerMessage,
	termsig chan struct{},
	handler func(context.Context, ConsumerMessage) error,
	timeout time.Duration,
	unsub bool,
	appliers ...mq.OptionApplier,
)

func TryWithPulsar(ctx context.Context, t testing.TB, dsn string) (context.Context, error)

func WithMySQL(ctx context.Context, t testing.TB, dsn string, catalogs ...builder.Catalog) (*confrdb.EndpointMySQL, error)

func WithPulsar(ctx context.Context, t testing.TB, dsn string) context.Context

func WithPulsarLost(ctx context.Context, t testing.TB, dsn string) context.Context

func WithRedis(ctx context.Context, t testing.TB, dsn string) context.Context

func WithRedisLost(ctx context.Context, t testing.TB, dsn string) context.Context

func WithXXLRegistry(ctx context.Context, t testing.TB, dsn string, executors ...string) context.Context