Batch is an iterator for batches of records.

DefaultQueryCtx returns a context with a sensible sanity limit timeout for SQL queries.

DefaultQueryCtxWithParent returns a context with a sensible sanity limit timeout for SQL queries with the given parent context.

GetTxFromContext extracts the tx from the context.

DEPRECATED: Use the transaction manager instead.

DEPRECATED: Use the transaction manager instead.

WARNING: Only use for nested txes inside ORM methods where you expect db to already have a ctx with a deadline.

InjectTxIntoContext injects the tx into the context.

MustSQLDB panics if there is an error getting the underlying SQL TX.

NewLock returns a Lock with *sql.Conn.

TxFromContext extracts the tx from the context.

WithTxOptions returns a TransactionOption which sets the sql.TxOptions on the transaction.

BatchSize is the default number of DB records to access in one batch.

Postgres channel to listen for new eth_txes.

IdleInTxSessionTimeout controls the max time we leave a transaction open and idle.

LockTimeout controls the max time we will wait for any kind of database lock.

Lock implements the Locker interface.

NullEventBroadcaster implements null pattern for event broadcaster.

EventBroadcaster opaquely manages a collection of Postgres event listeners and broadcasts events to subscribers (with an optional payload filter).

Locker is an interface for postgresql advisory locks.

Subscription represents a subscription to a Postgres event channel.

BatchFunc is the function to execute on each batch of records, should return the count of records affected.

TransactionManagerOption configures how we set up the transaction.

A TxFn is a function that will be called with a context which has a transaction injected as a value.