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

Method JobGetByID

riverdriver/river_driver_interface.go:219–219  ·  view source on GitHub ↗
(ctx context.Context, params *JobGetByIDParams)

Source from the content-addressed store, hash-verified

217 JobDeleteMany(ctx context.Context, params *JobDeleteManyParams) ([]*rivertype.JobRow, error)
218 JobGetAvailable(ctx context.Context, params *JobGetAvailableParams) ([]*rivertype.JobRow, error)
219 JobGetByID(ctx context.Context, params *JobGetByIDParams) (*rivertype.JobRow, error)
220 JobGetByIDMany(ctx context.Context, params *JobGetByIDManyParams) ([]*rivertype.JobRow, error)
221 JobGetByKindMany(ctx context.Context, params *JobGetByKindManyParams) ([]*rivertype.JobRow, error)
222 JobGetStuck(ctx context.Context, params *JobGetStuckParams) ([]*rivertype.JobRow, error)

Callers 15

TestJobCompleteTxFunction · 0.65
Test_Client_JobDeleteTxFunction · 0.65
Test_Client_JobDeleteManyFunction · 0.65
Test_Client_JobDeleteManyTxFunction · 0.65
Test_Client_MaintenanceFunction · 0.65
TestResumableSetStepTxFunction · 0.65
JobGetMethod · 0.65
JobGetTxMethod · 0.65
TestTestSchemaFunction · 0.65
TestTestTxFunction · 0.65
JobGetByIDMethod · 0.65
JobGetByIDMethod · 0.65

Implementers 3

Executorriverdriver/riverpgxv5/river_pgx_v5_dr
Executorriverdriver/riverdatabasesql/river_dat
Executorriverdriver/riversqlite/river_sqlite_d

Calls

no outgoing calls

Tested by 15

TestJobCompleteTxFunction · 0.52
Test_Client_JobDeleteTxFunction · 0.52
Test_Client_JobDeleteManyFunction · 0.52
Test_Client_JobDeleteManyTxFunction · 0.52
Test_Client_MaintenanceFunction · 0.52
TestResumableSetStepTxFunction · 0.52
TestTestSchemaFunction · 0.52
TestTestTxFunction · 0.52
ExerciseClientFunction · 0.52
TestJobSchedulerFunction · 0.52
TestJobRescuerFunction · 0.52
TestJobCleanerFunction · 0.52