interface PostgresStreamOptions {
    application_name?: string;
    connectionString?: string;
    connectionTimeoutMillis?: number;
    consumerTablePrefix?: string;
    database?: string;
    host?: string;
    idleTimeoutMillis?: number;
    keepAlive?: boolean;
    keepAliveInitialDelayMillis?: number;
    max?: number;
    maxRetries?: number;
    password?: string;
    port?: number;
    retryDelay?: number;
    schema?: string;
    ssl?: boolean | Record<string, unknown>;
    streamTablePrefix?: string;
    user?: string;
}

Hierarchy (view full)

Properties

application_name?: string

Reported in pg_stat_activity.application_name.

connectionString?: string
connectionTimeoutMillis?: number

Milliseconds to wait for a connection before failing (pg default: forever).

consumerTablePrefix?: string
database?: string
host?: string
idleTimeoutMillis?: number
keepAlive?: boolean

Enable TCP keepalive on the socket.

keepAliveInitialDelayMillis?: number

Idle time before the first TCP keepalive probe.

max?: number
maxRetries?: number
password?: string
port?: number
retryDelay?: number
schema?: string
ssl?: boolean | Record<string, unknown>
streamTablePrefix?: string
user?: string