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

Method UnwrapExecutor

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

UnwrapExecutor gets an executor from a driver transaction. API is not stable. DO NOT USE.

(tx TTx)

Source from the content-addressed store, hash-verified

166 //
167 // API is not stable. DO NOT USE.
168 UnwrapExecutor(tx TTx) ExecutorTx
169
170 // UnwrapTx gets a driver transaction from an executor. This is currently
171 // only needed for test transaction helpers.

Callers 15

resumableSetStepTxFunction · 0.65
Test_SubscriptionManagerFunction · 0.65
TestJobCompleteTxFunction · 0.65
Test_Client_JobDeleteTxFunction · 0.65
Test_Client_JobDeleteManyTxFunction · 0.65
Test_Client_InsertManyFastTxFunction · 0.65
Test_Client_InsertManyTxFunction · 0.65
Test_Client_JobUpdateTxFunction · 0.65
Test_Client_QueueGetTxFunction · 0.65
Test_Client_QueueListTxFunction · 0.65
Test_Client_QueueUpdateTxFunction · 0.65
JobCompleteTxFunction · 0.65

Implementers 3

Driverriverdriver/riverpgxv5/river_pgx_v5_dr
Driverriverdriver/riverdatabasesql/river_dat
Driverriverdriver/riversqlite/river_sqlite_d

Calls

no outgoing calls

Tested by 15

Test_SubscriptionManagerFunction · 0.52
TestJobCompleteTxFunction · 0.52
Test_Client_JobDeleteTxFunction · 0.52
Test_Client_JobDeleteManyTxFunction · 0.52
Test_Client_InsertManyFastTxFunction · 0.52
Test_Client_InsertManyTxFunction · 0.52
Test_Client_JobUpdateTxFunction · 0.52
Test_Client_QueueGetTxFunction · 0.52
Test_Client_QueueListTxFunction · 0.52
Test_Client_QueueUpdateTxFunction · 0.52
TestResumableSetStepTxFunction · 0.52
TestProducer_PollOnlyFunction · 0.52