riverprodrivertest

package module

v0.19.0 Go to latest

Published: Oct 8, 2025 License: Proprietary

Index ¶

func Benchmark[TTx any](ctx context.Context, b *testing.B, driverWithPool func(ctx context.Context, b *testing.B) (riverprodriver.ProDriver[TTx], string), executorWithTx func(ctx context.Context, b *testing.B) riverprodriver.ProExecutor, )
func Exercise[TTx any](ctx context.Context, t *testing.T, driverWithSchema func(ctx context.Context, t *testing.T, opts *riverdbtest.TestSchemaOpts) (riverprodriver.ProDriver[TTx], string), executorWithTx func(ctx context.Context, t *testing.T) (riverprodriver.ProExecutor, riverprodriver.ProDriver[TTx]), )

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Benchmark ¶

func Benchmark[TTx any](ctx context.Context, b *testing.B,
	driverWithPool func(ctx context.Context, b *testing.B) (riverprodriver.ProDriver[TTx], string),
	executorWithTx func(ctx context.Context, b *testing.B) riverprodriver.ProExecutor,
)

func Exercise ¶

func Exercise[TTx any](ctx context.Context, t *testing.T,
	driverWithSchema func(ctx context.Context, t *testing.T, opts *riverdbtest.TestSchemaOpts) (riverprodriver.ProDriver[TTx], string),
	executorWithTx func(ctx context.Context, t *testing.T) (riverprodriver.ProExecutor, riverprodriver.ProDriver[TTx]),
)

Exercise fully exercises a driver. The driver's listener is exercised if supported.

Types ¶

This section is empty.

riverqueue.com/riverpro/driver/riverprodrivertest

v0.19.0