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

Method JobDelete

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

Source from the content-addressed store, hash-verified

213 JobCountByQueueAndState(ctx context.Context, params *JobCountByQueueAndStateParams) ([]*JobCountByQueueAndStateResult, error)
214 JobCountByState(ctx context.Context, params *JobCountByStateParams) (int, error)
215 JobDelete(ctx context.Context, params *JobDeleteParams) (*rivertype.JobRow, error)
216 JobDeleteBefore(ctx context.Context, params *JobDeleteBeforeParams) (int, error)
217 JobDeleteMany(ctx context.Context, params *JobDeleteManyParams) ([]*rivertype.JobRow, error)
218 JobGetAvailable(ctx context.Context, params *JobGetAvailableParams) ([]*rivertype.JobRow, error)

Callers 10

TestJobCompleteTxFunction · 0.65
Test_Client_JobDeleteFunction · 0.65
TestResumableSetStepTxFunction · 0.65
JobDeleteMethod · 0.65
JobDeleteTxMethod · 0.65
JobDeleteMethod · 0.65
JobDeleteMethod · 0.65
JobDeleteMethod · 0.65
exerciseJobDeleteFunction · 0.65
ExerciseClientFunction · 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 4

TestJobCompleteTxFunction · 0.52
Test_Client_JobDeleteFunction · 0.52
TestResumableSetStepTxFunction · 0.52
ExerciseClientFunction · 0.52