MCPcopy Index your code
hub / github.com/riverqueue/river / TestDBPool

Function TestDBPool

rivershared/riversharedtest/riversharedtest_test.go:11–23  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

9)
10
11func TestDBPool(t *testing.T) {
12 t.Parallel()
13
14 ctx := context.Background()
15
16 pool1 := DBPool(ctx, t)
17 _, err := pool1.Exec(ctx, "SELECT 1")
18 require.NoError(t, err)
19
20 // Both pools should be exactly the same object.
21 pool2 := DBPool(ctx, t)
22 require.Equal(t, pool1, pool2)
23}
24
25func TestWaitOrTimeout(t *testing.T) {
26 t.Parallel()

Callers

nothing calls this directly

Calls 2

DBPoolFunction · 0.85
ExecMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…