MCPcopy Create free account
hub / github.com/riverqueue/river / SharedTxRow

Struct SharedTxRow

internal/riverinternaltest/sharedtx/shared_tx.go:152–156  ·  view source on GitHub ↗

SharedTxRow wraps a pgx.Row such that it unlocks SharedExecutor when the row finishes scanning.

Source from the content-addressed store, hash-verified

150// SharedTxRow wraps a pgx.Row such that it unlocks SharedExecutor when
151// the row finishes scanning.
152type SharedTxRow struct {
153 sharedTxDerivative
154
155 innerRow pgx.Row
156}
157
158func (r *SharedTxRow) Scan(dest ...any) error {
159 defer r.unlockParent()

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected