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

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.

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.

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.