(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobInsertFastManyParams)
| 75 | } |
| 76 | |
| 77 | func (p *pilotSpy) JobInsertMany(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobInsertFastManyParams) ([]*riverdriver.JobInsertFastResult, error) { |
| 78 | p.jobInsertManyCalls.Add(1) |
| 79 | return p.StandardPilot.JobInsertMany(ctx, exec, params) |
| 80 | } |
| 81 | |
| 82 | func (p *pilotSpy) JobRetry(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobRetryParams) (*rivertype.JobRow, error) { |
| 83 | p.jobRetryCalls.Add(1) |
nothing calls this directly
no test coverage detected