Batch is an iterator for batches of records.

BulkDeleteRuns removes JobRuns and their related records: TaskRuns and RunResults.

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

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.

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

Sessions returns all sessions limited by the parameters.

TxFromContext extracts the tx from the context.

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

NOTE: All advisory lock class IDs used by the Chainlink application MUST be kept here to avoid accidental re-use.

NOTE: All advisory lock class IDs used by the Chainlink application MUST be kept here to avoid accidental re-use.

NOTE: All advisory lock class IDs used by the Chainlink application MUST be kept here to avoid accidental re-use.

ORM takes lock on 1027321974924625846 which splits into ClassID 239192036, ObjID 2840971190.

NOTE: All advisory lock class IDs used by the Chainlink application MUST be kept here to avoid accidental re-use.

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.

NullEventBroadcaster implements null pattern for event broadcaster.

go:generate mockery --name AdvisoryLocker --output ../../internal/mocks/ --case=underscore.

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

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.