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

Struct JobBothInsertAndWorkMiddleware

example_global_middleware_test.go:16–16  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

14)
15
16type JobBothInsertAndWorkMiddleware struct{ river.MiddlewareDefaults }
17
18func (JobBothInsertAndWorkMiddleware) InsertMany(ctx context.Context, manyParams []*rivertype.JobInsertParams, doInner func(ctx context.Context) ([]*rivertype.JobInsertResult, error)) ([]*rivertype.JobInsertResult, error) {
19 fmt.Printf("JobBothInsertAndWorkMiddleware.InsertMany ran\n")

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected