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

Function newDriverWithPlugin

plugin_test.go:68–74  ·  view source on GitHub ↗
(t *testing.T, dbPool *pgxpool.Pool)

Source from the content-addressed store, hash-verified

66}
67
68func newDriverWithPlugin(t *testing.T, dbPool *pgxpool.Pool) *TestDriverWithPlugin {
69 t.Helper()
70
71 return &TestDriverWithPlugin{
72 Driver: riverpgxv5.New(dbPool),
73 }
74}
75
76func (d *TestDriverWithPlugin) PluginInit(archetype *baseservice.Archetype) {
77 d.initCalled = true

Callers 3

TestClientDriverPluginFunction · 0.85
TestClientPilotPluginFunction · 0.85
Test_Client_PilotUsageFunction · 0.85

Calls 2

NewFunction · 0.92
HelperMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…