postgres

Import

Import

import * as api from "@fungi.computer/watchdog/postgres";

Exports

Kind	Export	Description
Ttype alias	PostgresWatchdog	PostgreSQL runtime with admission joined to the caller’s checked-out client.
Ttype alias	PostgresPurgeStatement	Parameterized queue purge joined to a producer’s existing PostgreSQL transaction.
constconstant	watchdogPostgresSchema	Package-owned schema statements, to run through the deployment migration owner.
fnfunction	createPostgresWatchdog()	Open the shared Effect engine on a migrated PostgreSQL database.
fnfunction	purgePostgresQueues()	Purge every attempt in the queues yielded by trusted producer SQL.

PostgresWatchdogTtype alias

Signature

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

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

---

PostgresPurgeStatementTtype alias

Signature

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

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

watchdogPostgresSchemaconstconstant

Signature

const watchdogPostgresSchema: readonly string[];

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

createPostgresWatchdog()fnfunction

Signature

function createPostgresWatchdog(options): PostgresWatchdog;

Open the shared Effect engine on a migrated PostgreSQL database.

Parameters

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

Returns

PostgresWatchdog

---

purgePostgresQueues()fnfunction

Signature

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

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

Parameters

Parameter	Type
source	PostgresPurgeStatement

Returns

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

References

AsyncWatchdogOptions

Re-exports AsyncWatchdogOptions

---

AsyncWatchdogRuntime

Re-exports AsyncWatchdogRuntime