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

Method QueuePause

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

Source from the content-addressed store, hash-verified

281 QueueList(ctx context.Context, params *QueueListParams) ([]*rivertype.Queue, error)
282 QueueNameList(ctx context.Context, params *QueueNameListParams) ([]string, error)
283 QueuePause(ctx context.Context, params *QueuePauseParams) error
284 QueueResume(ctx context.Context, params *QueueResumeParams) error
285 QueueUpdate(ctx context.Context, params *QueueUpdateParams) (*rivertype.Queue, error)
286 QueryRow(ctx context.Context, sql string, args ...any) Row

Callers 11

Example_queuePauseFunction · 0.65
Test_Client_CommonFunction · 0.65
Test_Client_QueueListFunction · 0.65
testProducerFunction · 0.65
QueuePauseMethod · 0.65
QueuePauseTxMethod · 0.65
QueuePauseMethod · 0.65
QueuePauseMethod · 0.65
QueuePauseMethod · 0.65
ExerciseClientFunction · 0.65
exerciseQueueFunction · 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 5

Example_queuePauseFunction · 0.52
Test_Client_CommonFunction · 0.52
Test_Client_QueueListFunction · 0.52
testProducerFunction · 0.52
ExerciseClientFunction · 0.52