Перейти к содержимому
Русский

PostgresDurableStateStore

Это содержимое пока не доступно на вашем языке.

Defined in: src/persistence/durable-state-stores/PostgresDurableStateStore.ts:14

DurableStateStore backed by PostgreSQL (pg) — the first SQL-based durable-state store (SQLite and Cassandra ship journal + snapshot only).

Behaviour lives in RelationalDurableStateStore; this class supplies the Postgres dialect, whose revision-0 insert carries ON CONFLICT DO NOTHING so a collision shows up as zero affected rows rather than a thrown error.

  • RelationalDurableStateStore

new PostgresDurableStateStore(options?): PostgresDurableStateStore

Defined in: src/persistence/durable-state-stores/PostgresDurableStateStore.ts:15

PostgresDurableStateStoreOptions = {}

PostgresDurableStateStore

RelationalDurableStateStore.constructor

close(): Promise<void>

Defined in: src/persistence/LazyStore.ts:66

Promise<void>

RelationalDurableStateStore.close


delete(persistenceId): Promise<void>

Defined in: src/persistence/relational/RelationalDurableStateStore.ts:137

Remove the record entirely. Idempotent.

string

Promise<void>

RelationalDurableStateStore.delete


load<S>(persistenceId, _options?): Promise<Option<DurableStateRecord<S>>>

Defined in: src/persistence/relational/RelationalDurableStateStore.ts:124

Load the latest record for persistenceId, or None if none exists. options.encryption is required when client-side encryption was used at write time.

S

string

PersistenceOptions

Promise<Option<DurableStateRecord<S>>>

RelationalDurableStateStore.load


upsert<S>(persistenceId, expectedRevision, state, _options?): Promise<DurableStateRecord<S>>

Defined in: src/persistence/relational/RelationalDurableStateStore.ts:76

Upsert the state for persistenceId. expectedRevision must match the current stored revision (0 when no record exists yet). Throws DurableStateConcurrencyError on conflict. Optional options carry per-call preferences from the caller (e.g. compression / encryption set on the actor); stores that cannot honour them silently ignore the field.

S

string

number

S

PersistenceOptions

Promise<DurableStateRecord<S>>

RelationalDurableStateStore.upsert