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

Method QueueCreateOrSetUpdatedAt

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

Source from the content-addressed store, hash-verified

276 PGAdvisoryXactLock(ctx context.Context, key int64) (*struct{}, error)
277
278 QueueCreateOrSetUpdatedAt(ctx context.Context, params *QueueCreateOrSetUpdatedAtParams) (*rivertype.Queue, error)
279 QueueDeleteExpired(ctx context.Context, params *QueueDeleteExpiredParams) ([]string, error)
280 QueueGet(ctx context.Context, params *QueueGetParams) (*rivertype.Queue, error)
281 QueueList(ctx context.Context, params *QueueListParams) ([]*rivertype.Queue, error)

Callers 7

StartWorkContextMethod · 0.65
reportQueueStatusOnceMethod · 0.65
QueueFunction · 0.65
QueueCreateOrSetUpdatedAtMethod · 0.65
QueueCreateOrSetUpdatedAtMethod · 0.65
QueueCreateOrSetUpdatedAtMethod · 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

no test coverage detected