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

Method JobRetry

rivershared/riverpilot/pilot.go:44–44  ·  view source on GitHub ↗
(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobRetryParams)

Source from the content-addressed store, hash-verified

42 ) ([]*riverdriver.JobInsertFastResult, error)
43
44 JobRetry(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobRetryParams) (*rivertype.JobRow, error)
45
46 JobSetStateIfRunningMany(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobSetStateIfRunningManyParams) ([]*rivertype.JobRow, error)
47

Callers 5

Test_Client_JobRetryFunction · 0.65
jobRetryMethod · 0.65
JobRetryMethod · 0.65
Test_Client_PilotUsageFunction · 0.65
JobRetryMethod · 0.65

Implementers 2

pilotSpyclient_pilot_test.go
StandardPilotrivershared/riverpilot/standard_pilot.

Calls

no outgoing calls

Tested by 3

Test_Client_JobRetryFunction · 0.52
JobRetryMethod · 0.52
Test_Client_PilotUsageFunction · 0.52