EventQueueExecutor
Defined in: packages/server/src/events/queue.ts:29
The minimal SQL seam a backend executes through — satisfied by a drizzle PgAsyncDatabase AND by the
transaction handle its transaction() callback receives. The ingestion endpoint enqueues INSIDE its own
transaction (a batch is enqueued atomically or the request fails retryably), so every mutating method
takes an optional executor rather than owning a connection.
Properties
Section titled “Properties”execute
Section titled “execute”execute: (
query) =>Promise<unknown>
Defined in: packages/server/src/events/queue.ts:30
Parameters
Section titled “Parameters”SQL
Returns
Section titled “Returns”Promise<unknown>