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

Method JobCancel

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

Source from the content-addressed store, hash-verified

209 IndexReindexArtifacts(ctx context.Context, params *IndexReindexArtifactsParams) ([]string, error)
210
211 JobCancel(ctx context.Context, params *JobCancelParams) (*rivertype.JobRow, error)
212 JobCountByAllStates(ctx context.Context, params *JobCountByAllStatesParams) (map[rivertype.JobState]int, error)
213 JobCountByQueueAndState(ctx context.Context, params *JobCountByQueueAndStateParams) ([]*JobCountByQueueAndStateResult, error)
214 JobCountByState(ctx context.Context, params *JobCountByStateParams) (int, error)

Callers 4

JobCancelMethod · 0.65
JobCancelMethod · 0.65
JobCancelMethod · 0.65
exerciseJobUpdateFunction · 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

no test coverage detected