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

Interface ExecutorTx

riverdriver/river_driver_interface.go:302–314  ·  view source on GitHub ↗

ExecutorTx is an executor which is a transaction. In addition to standard Executor operations, it may be committed or rolled back. API is not stable. DO NOT IMPLEMENT.

Source from the content-addressed store, hash-verified

300//
301// API is not stable. DO NOT IMPLEMENT.
302type ExecutorTx interface {
303 Executor
304
305 // Commit commits the transaction.
306 //
307 // API is not stable. DO NOT USE.
308 Commit(ctx context.Context) error
309
310 // Rollback rolls back the transaction.
311 //
312 // API is not stable. DO NOT USE.
313 Rollback(ctx context.Context) error
314}
315
316type GetListenenerParams struct {
317 Schema string

Callers 16

Example_insertAndWorkFunction · 0.65
WorkMethod · 0.65
Test_Client_CommonFunction · 0.65
WorkMethod · 0.65
QueuePauseMethod · 0.65
QueueResumeMethod · 0.65
Example_insertAndWorkFunction · 0.65
WorkMethod · 0.65
Test_Client_CommonFunction · 0.65
Test_Client_JobDeleteTxFunction · 0.65

Implementers 7

ExecutorTxriverdriver/riverpgxv5/river_pgx_v5_dr
ExecutorTxriverdriver/riverdatabasesql/river_dat
ExecutorSubTxriverdriver/riverdatabasesql/river_dat
ExecutorTxriverdriver/riversqlite/river_sqlite_d
ExecutorSubTxriverdriver/riversqlite/river_sqlite_d
SharedTxinternal/riverinternaltest/sharedtx/sh
SharedSubTxinternal/riverinternaltest/sharedtx/sh

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…