PostgresDeadLetterTransport
Αυτό το περιεχόμενο δεν είναι ακόμη διαθέσιμο στη γλώσσα σου.
Defined in: packages/pipeline-deadletter/src/transports/postgres.transport.ts:83
DeadLetterStore backed by Postgres (pg): inserts each dead
letter as a row and keeps it, so it can be listed, redriven with
DeadLetterRedriver, and resolved. Create the table once with
createDeadLetterTableSql.
The table name is validated as a plain SQL identifier (it is interpolated, not parameterized); all values are bound parameters.
Example
Section titled “Example”await pool.query(createDeadLetterTableSql());const store = new PostgresDeadLetterTransport(pool);const open = await store.list({ status: 'open' });Implements
Section titled “Implements”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new PostgresDeadLetterTransport(
db,options?):PostgresDeadLetterTransport
Defined in: packages/pipeline-deadletter/src/transports/postgres.transport.ts:86
Parameters
Section titled “Parameters”options?
Section titled “options?”PostgresDeadLetterTransportOptions = {}
Returns
Section titled “Returns”PostgresDeadLetterTransport
Methods
Section titled “Methods”get(
id):Promise<DeadLetterRecord|undefined>
Defined in: packages/pipeline-deadletter/src/transports/postgres.transport.ts:116
The record with this id, or undefined.
Parameters
Section titled “Parameters”string
Returns
Section titled “Returns”Promise<DeadLetterRecord | undefined>
Implementation of
Section titled “Implementation of”list()
Section titled “list()”list(
filter?):Promise<DeadLetterRecord[]>
Defined in: packages/pipeline-deadletter/src/transports/postgres.transport.ts:123
Records matching the filter, oldest first.
Parameters
Section titled “Parameters”filter?
Section titled “filter?”DeadLetterListFilter = {}
Returns
Section titled “Returns”Implementation of
Section titled “Implementation of”markResolved()
Section titled “markResolved()”markResolved(
id):Promise<void>
Defined in: packages/pipeline-deadletter/src/transports/postgres.transport.ts:141
Closes the record.
Parameters
Section titled “Parameters”string
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”recordAttempt()
Section titled “recordAttempt()”recordAttempt(
id,error):Promise<void>
Defined in: packages/pipeline-deadletter/src/transports/postgres.transport.ts:134
Counts one failed redrive attempt and keeps its error.
Parameters
Section titled “Parameters”string
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”send()
Section titled “send()”send(
record):Promise<void>
Defined in: packages/pipeline-deadletter/src/transports/postgres.transport.ts:93
Persist / publish a single dead-letter record.
Implementations should be resilient and fast; a throw here is caught by the behavior and logged, but never masks the original handler error.
Parameters
Section titled “Parameters”record
Section titled “record”The failed request snapshot to forward.
Returns
Section titled “Returns”Promise<void>