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

Method NotifyMany

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

Source from the content-addressed store, hash-verified

273 NotificationDeleteBefore(ctx context.Context, params *NotificationDeleteBeforeParams) (int, error)
274
275 NotifyMany(ctx context.Context, params *NotifyManyParams) error
276 PGAdvisoryXactLock(ctx context.Context, key int64) (*struct{}, error)
277
278 QueueCreateOrSetUpdatedAt(ctx context.Context, params *QueueCreateOrSetUpdatedAtParams) (*rivertype.Queue, error)

Callers 7

emitQueueNotificationFunction · 0.65
maybeNotifyInsertForQueuesMethod · 0.65
notifyQueuePauseOrResumeMethod · 0.65
requestResignTxMethod · 0.65
queueUpdateMethod · 0.65
exerciseListenerFunction · 0.65
sendNotificationFunction · 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 2

emitQueueNotificationFunction · 0.52
sendNotificationFunction · 0.52