Skip to content

ObjectStorageDurableStateStore

Defined in: src/persistence/durable-state-stores/ObjectStorageDurableStateStore.ts:61

new ObjectStorageDurableStateStore(opts): ObjectStorageDurableStateStore

Defined in: src/persistence/durable-state-stores/ObjectStorageDurableStateStore.ts:68

ObjectStorageDurableStateStoreOptions

ObjectStorageDurableStateStore

close(): Promise<void>

Defined in: src/persistence/durable-state-stores/ObjectStorageDurableStateStore.ts:195

Promise<void>


delete(pid): Promise<void>

Defined in: src/persistence/durable-state-stores/ObjectStorageDurableStateStore.ts:190

Remove the record entirely. Idempotent.

string

Promise<void>

DurableStateStore.delete


forgetEtagForTest(pid): void

Defined in: src/persistence/durable-state-stores/ObjectStorageDurableStateStore.ts:201

Test hook — drop the cached ETag for a pid (simulates actor restart).

string

void


load<S>(pid, options?): Promise<Option<DurableStateRecord<S>>>

Defined in: src/persistence/durable-state-stores/ObjectStorageDurableStateStore.ts:75

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>>>

DurableStateStore.load


upsert<S>(pid, expectedRevision, state, options?): Promise<DurableStateRecord<S>>

Defined in: src/persistence/durable-state-stores/ObjectStorageDurableStateStore.ts:100

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>>

DurableStateStore.upsert