Skip to content

PgPubSubOptions

Mykhailo Stadnyk edited this page Nov 23, 2020 · 5 revisions

Globals / PgPubSubOptions

Interface: PgPubSubOptions

Options accepted as option argument of PgPubSub constructor. It extends pg.ClientConfig options, mostly because it is used to construct PostgreSQL database connection, adding more properties required to configure PgBubSub objects behavior.

Hierarchy

  • ClientConfig

    ↳ PgPubSubOptions

Index

Properties

Properties

acquireInterval

• acquireInterval: number

Time interval in milliseconds before LISTEN clients would re-try to acquire channel locks. It works from one hand as connection keep-alive periodical pings, from other hand adds additional level of reliability for the cases when connection, which holds the lock has been suddenly disconnected in a silent manner.

By default is set to 30000ms (30sec). Please, assume this value should be selected for a particular system with care of often acquire lock hits and overall infrastructure reliability.


application_name

• Optional application_name: undefined | string

Inherited from PgPubSubOptions.application_name


connectionString

• Optional connectionString: undefined | string

Inherited from PgPubSubOptions.connectionString


connectionTimeoutMillis

• Optional connectionTimeoutMillis: undefined | number

Inherited from PgPubSubOptions.connectionTimeoutMillis


database

• Optional database: undefined | string

Inherited from PgPubSubOptions.database


filtered

• filtered: boolean

If set to true, self emitted messages (those which were sent using NOTIFY on the same connection) will be filtered on this connection. By default is false - means that connection will LISTEN to the messages, which were notified on the same connection.


host

• Optional host: undefined | string

Inherited from PgPubSubOptions.host


idle_in_transaction_session_timeout

• Optional idle_in_transaction_session_timeout: undefined | number

Inherited from PgPubSubOptions.idle_in_transaction_session_timeout


keepAlive

• Optional keepAlive: undefined | false | true

Inherited from PgPubSubOptions.keepAlive


keepAliveInitialDelayMillis

• Optional keepAliveInitialDelayMillis: undefined | number

Inherited from PgPubSubOptions.keepAliveInitialDelayMillis


parseInputDatesAsUTC

• Optional parseInputDatesAsUTC: undefined | false | true

Inherited from PgPubSubOptions.parseInputDatesAsUTC


password

• Optional password: string | () => string | Promise<string>

Inherited from PgPubSubOptions.password


pgClient

• Optional pgClient: Client

Existing PostgreSQL client connection (optional). Can be passed if there is a need to re-use existing db connection from external code. Otherwise it is required to bypass correct options to instantiate new pg.Client connection properly.


port

• Optional port: undefined | number

Inherited from PgPubSubOptions.port


query_timeout

• Optional query_timeout: undefined | number

Inherited from PgPubSubOptions.query_timeout


retryDelay

• retryDelay: number

Specifies delay in milliseconds between re-connection retries


retryLimit

• retryLimit: number

Specifies maximum number of re-connection retries to process, before connection would be treated as broken (disconnected). By default is set to infinite number of retries.


singleListener

• singleListener: boolean

Boolean flag, which turns off/on single listener mode. By default is set to true, so instantiated PgPubSub connections will act using inter-process locking mechanism.


ssl

• Optional ssl: boolean | ConnectionOptions

Inherited from PgPubSubOptions.ssl


statement_timeout

• Optional statement_timeout: false | number

Inherited from PgPubSubOptions.statement_timeout


stream

• Optional stream: stream.Duplex

Inherited from PgPubSubOptions.stream


user

• Optional user: undefined | string

Inherited from PgPubSubOptions.user

Clone this wiki locally