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

Function requireNotInserted

rivertest/rivertest.go:219–225  ·  view source on GitHub ↗
(ctx context.Context, t testingT, driver TDriver, expectedJob TArgs, opts *RequireInsertedOpts)

Source from the content-addressed store, hash-verified

217}
218
219func requireNotInserted[TDriver riverdriver.Driver[TTx], TTx any, TArgs river.JobArgs](ctx context.Context, t testingT, driver TDriver, expectedJob TArgs, opts *RequireInsertedOpts) {
220 t.Helper()
221 err := requireNotInsertedErr[TDriver](ctx, t, driver.GetExecutor(), expectedJob, opts)
222 if err != nil {
223 failuref(t, "Internal failure: %s", err)
224 }
225}
226
227// RequireNotInsertedTx is a test helper that verifies that a job of the given
228// kind was not inserted for work, failing the test if one was.

Callers 2

TestRequireNotInsertedFunction · 0.85
RequireNotInsertedFunction · 0.85

Calls 3

failurefFunction · 0.85
HelperMethod · 0.65
GetExecutorMethod · 0.65

Tested by 1

TestRequireNotInsertedFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…