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

Method Begin

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

Begin begins a new subtransaction. ErrSubTxNotSupported may be returned if the executor is a transaction and the driver doesn't support subtransactions (like riverdriver/riverdatabasesql for database/sql).

(ctx context.Context)

Source from the content-addressed store, hash-verified

183 // if the executor is a transaction and the driver doesn't support
184 // subtransactions (like riverdriver/riverdatabasesql for database/sql).
185 Begin(ctx context.Context) (ExecutorTx, error)
186
187 // ColumnExists checks whether a column for a particular table exists for
188 // the schema in the current search schema.

Callers 15

Example_insertAndWorkFunction · 0.65
WorkMethod · 0.65
Test_Client_CommonFunction · 0.65
Test_Client_JobDeleteTxFunction · 0.65
Test_Client_InsertTxFunction · 0.65
Test_Client_InsertManyTxFunction · 0.65
Test_Client_JobUpdateTxFunction · 0.65
Test_Client_QueueGetTxFunction · 0.65
Test_Client_QueueListTxFunction · 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 15

Example_insertAndWorkFunction · 0.52
WorkMethod · 0.52
Test_Client_CommonFunction · 0.52
Test_Client_JobDeleteTxFunction · 0.52
Test_Client_InsertTxFunction · 0.52
Test_Client_InsertManyTxFunction · 0.52
Test_Client_JobUpdateTxFunction · 0.52
Test_Client_QueueGetTxFunction · 0.52
Test_Client_QueueListTxFunction · 0.52