riverdrivertest

Documentation

Index

• func ExerciseExecutorFull[TTx any](ctx context.Context, t *testing.T, driver riverdriver.Driver[TTx], ...)
• func ExerciseExecutorMigrationOnly[TTx any](ctx context.Context, t *testing.T, driver riverdriver.Driver[TTx], ...)
• func ExerciseListener[TTx any](ctx context.Context, t *testing.T, ...)

Functions

func ExerciseExecutorFull

func ExerciseExecutorFull[TTx any](ctx context.Context, t *testing.T, driver riverdriver.Driver[TTx], beginTx func(ctx context.Context, t *testing.T) TTx)

ExerciseExecutorFull exercises a driver that's expected to provide full functionality.

func ExerciseExecutorMigrationOnly

func ExerciseExecutorMigrationOnly[TTx any](ctx context.Context, t *testing.T, driver riverdriver.Driver[TTx], beginTx func(ctx context.Context, t *testing.T) TTx)

ExerciseExecutorMigrationOnly exercises a driver that's expected to only be able to perform database migrations, and not full River functionality.

func ExerciseListener

func ExerciseListener[TTx any](ctx context.Context, t *testing.T, getDriverWithPool func(ctx context.Context, t *testing.T) riverdriver.Driver[TTx])