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

Struct ExecutorSubTx

riverdriver/riversqlite/river_sqlite_driver.go:1379–1385  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1377}
1378
1379type ExecutorSubTx struct {
1380 Executor
1381
1382 beginOnce *savepointutil.BeginOnlyOnce
1383 savepointNum int
1384 tx *sql.Tx
1385}
1386
1387const savepointPrefix = "river_savepoint_"
1388

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected