| 26 | } |
| 27 | |
| 28 | type JobInsertMiddleware struct{ river.MiddlewareDefaults } |
| 29 | |
| 30 | func (JobInsertMiddleware) InsertMany(ctx context.Context, manyParams []*rivertype.JobInsertParams, doInner func(ctx context.Context) ([]*rivertype.JobInsertResult, error)) ([]*rivertype.JobInsertResult, error) { |
| 31 | fmt.Printf("JobInsertMiddleware.InsertMany ran\n") |
nothing calls this directly
no outgoing calls
no test coverage detected