RememberEntitiesStore
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:27
Pluggable persistence backend for the sharded-entity registry. The
default JournalRememberEntitiesStore reuses the system’s Journal
— same plumbing that backs PersistentActor, so any Journal
implementation (in-memory, SQLite, Cassandra, …) works out of the
box. Custom impls can hit a different store entirely (e.g. a
standalone SQLite DB for the registry, separate from the event
journal).
Concurrency: append is called serially by the coordinator
(it chains writes via a promise-of-the-last-write), so impls don’t
need to handle concurrent appends to the same typeName.
Methods
Section titled “Methods”append()
Section titled “append()”append(
typeName,event):Promise<void>
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:29
Persist a single entity-lifecycle event.
Parameters
Section titled “Parameters”typeName
Section titled “typeName”string
Returns
Section titled “Returns”Promise<void>
clear()
Section titled “clear()”clear(
typeName):Promise<void>
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:39
Forget every event for typeName. Used by tests + reset tooling.
Parameters
Section titled “Parameters”typeName
Section titled “typeName”string
Returns
Section titled “Returns”Promise<void>
load()
Section titled “load()”load(
typeName):Promise<RememberEvent[]>
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:36
Replay every event ever recorded for typeName, in append order.
Returns an empty array if nothing’s been written. Called once
per coordinator preStart.
Parameters
Section titled “Parameters”typeName
Section titled “typeName”string
Returns
Section titled “Returns”Promise<RememberEvent[]>