Ir al contenido
Español

PostgresSnapshotStore

Esta página aún no está disponible en tu idioma.

Defined in: src/persistence/snapshot-stores/PostgresSnapshotStore.ts:35

SnapshotStore backed by PostgreSQL (pg). One row per (persistence_id, sequence_nr); loadLatest is an indexed ORDER BY sequence_nr DESC LIMIT 1. Prune-on-save keeps the newest keepN. PersistenceOptions (compression/encryption) are ignored — like the SQLite and Cassandra stores, payloads are stored as JSON text.

new PostgresSnapshotStore(options?): PostgresSnapshotStore

Defined in: src/persistence/snapshot-stores/PostgresSnapshotStore.ts:45

PostgresSnapshotStoreOptions = {}

PostgresSnapshotStore

close(): Promise<void>

Defined in: src/persistence/snapshot-stores/PostgresSnapshotStore.ts:102

Best-effort teardown.

Promise<void>

SnapshotStore.close


delete(pid, toSeq): Promise<void>

Defined in: src/persistence/snapshot-stores/PostgresSnapshotStore.ts:94

Delete snapshots up to and including toSeq. Useful for pruning.

string

number

Promise<void>

SnapshotStore.delete


loadBefore<S>(pid, seq, _options?): Promise<Option<Snapshot<S>>>

Defined in: src/persistence/snapshot-stores/PostgresSnapshotStore.ts:84

Load the newest snapshot with sequenceNr < seq, or None.

S

string

number

PersistenceOptions

Promise<Option<Snapshot<S>>>

SnapshotStore.loadBefore


loadLatest<S>(pid, _options?): Promise<Option<Snapshot<S>>>

Defined in: src/persistence/snapshot-stores/PostgresSnapshotStore.ts:74

Load the newest snapshot for pid, or None if none exist. options.encryption is required when client-side encryption was used at write time — the store has no other way to obtain the master key. Stores that don’t encrypt ignore the field.

S

string

PersistenceOptions

Promise<Option<Snapshot<S>>>

SnapshotStore.loadLatest


save<S>(pid, seq, state, _options?): Promise<Snapshot<S>>

Defined in: src/persistence/snapshot-stores/PostgresSnapshotStore.ts:52

Persist a snapshot at seq — typically the seq of the latest event applied. 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<Snapshot<S>>

SnapshotStore.save