hack

func Check ¶

func Check(t testing.TB)

func Context ¶

func Context(t testing.TB) context.Context

func DialWS ¶ added in v0.5.5

func DialWS(t testing.TB, ep *confws.Endpoint) *websocket.Conn

DialWS 拨到 ep.String();失败则 Fatal;测试结束自动 Close.

func NewWSEndpoint ¶ added in v0.5.5

func NewWSEndpoint(t testing.TB, setup func(*confws.Endpoint)) *confws.Endpoint

NewWSEndpoint 初始化并监听可拨号的 confws.Endpoint(127.0.0.1:0,/ws,默认禁用空闲回收). setup 在 Init 前调用,用于挂钩子/改配置;测试结束自动 Close.

func RunPulsarPubSubTestSuite ¶ added in v0.3.0

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 RunRabbitMQPubSubTestSuite ¶ added in v0.4.7

func RunRabbitMQPubSubTestSuite(
	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 ¶ added in v0.2.20

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

func TryWithRabbitMQ ¶ added in v0.4.7

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

func WithMySQL ¶ added in v0.4.1

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

func WithPulsar ¶ added in v0.2.3

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

func WithPulsarLost ¶ added in v0.2.3

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

func WithRabbitMQ ¶ added in v0.4.7

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

func WithRabbitMQLost ¶ added in v0.4.7

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

func WithRedis ¶

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

func WithRedisLost ¶

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

func WithXXLRegistry ¶ added in v0.4.0

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