rivertest

Nov 13, 2023

Changes in this version

+ func BaseServiceArchetype(tb testing.TB) *baseservice.Archetype

+ func DatabaseConfig(databaseName string) *pgxpool.Config

+ func DiscardContinuously[T any](drainChan <-chan T) func()

+ func DrainContinuously[T any](drainChan <-chan T) func() []T

+ func Logger(tb testing.TB) *slog.Logger

+ func LoggerWarn(tb testing.TB) *slog.Logger

+ func StubTime(archetype *baseservice.Archetype, t time.Time) time.Time

+ func TestDB(ctx context.Context, tb testing.TB) *pgxpool.Pool

+ func TestTx(ctx context.Context, tb testing.TB) pgx.Tx

+ func WaitOrTimeout[T any](t *testing.T, waitChan <-chan T) T

+ func WrapTestMain(m *testing.M)