| 158 | } |
| 159 | |
| 160 | type Executor struct { |
| 161 | dbPool *sql.DB |
| 162 | dbtx templateReplaceWrapper |
| 163 | driver *Driver |
| 164 | execTx riverdriver.ExecutorTx |
| 165 | } |
| 166 | |
| 167 | func (e *Executor) Begin(ctx context.Context) (riverdriver.ExecutorTx, error) { |
| 168 | if e.execTx != nil { |
nothing calls this directly
no outgoing calls
no test coverage detected