postgres

Type Aliases

PostgresWatchdog

PostgresWatchdog = AsyncWatchdogRuntime & Readonly<{ enqueue: (client, job) => Promise<void>>; }>

PostgreSQL runtime with admission joined to the caller’s checked-out client.

---

PostgresPurgeStatement

PostgresPurgeStatement = Readonly<{ text: string; values: readonly (string | number | null)[]; }>

Parameterized queue purge joined to a producer’s existing PostgreSQL transaction.

Variables

watchdogPostgresSchema

const watchdogPostgresSchema: readonly string[]

Package-owned schema statements, to run through the deployment migration owner.

Functions

createPostgresWatchdog()

createPostgresWatchdog(options): PostgresWatchdog

Open the shared Effect engine on a migrated PostgreSQL database.

Parameters

options

Readonly<{ execute: WatchdogExecutor; wake: Readonly<{ recompute: () => Promise<void>; }>; now?: () => number; }> & Readonly<{ database: Pick<Pool, "query">; }>

Returns

PostgresWatchdog

---

purgePostgresQueues()

purgePostgresQueues(source): readonly Readonly<{ text: string; values: readonly (string | number | null)[]; }>[]

Purge every attempt in the queues yielded by trusted producer SQL.

Parameters

source

PostgresPurgeStatement

Returns

readonly Readonly<{ text: string; values: readonly (string | number | null)[]; }>[]

References

AsyncWatchdogOptions

Re-exports AsyncWatchdogOptions

---

AsyncWatchdogRuntime

Re-exports AsyncWatchdogRuntime