JournalRememberEntitiesStore
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:51
Default RememberEntitiesStore impl backed by any Journal.
Stores events under persistenceId = "sharding-coordinator-{typeName}"
so a custom journal layout doesn’t collide with regular event-
sourced actors (which use the user-defined persistenceId).
Tagged with 'sharding-remember' so users can spot the registry
in tag-based projections / queries if they want to audit it.
Implements
Section titled “Implements”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new JournalRememberEntitiesStore(
journal):JournalRememberEntitiesStore
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:52
Parameters
Section titled “Parameters”journal
Section titled “journal”Returns
Section titled “Returns”JournalRememberEntitiesStore
Methods
Section titled “Methods”append()
Section titled “append()”append(
typeName,event):Promise<void>
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:58
Persist a single entity-lifecycle event.
Parameters
Section titled “Parameters”typeName
Section titled “typeName”string
Returns
Section titled “Returns”Promise<void>
Implementation of
Section titled “Implementation of”clear()
Section titled “clear()”clear(
typeName):Promise<void>
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:70
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>
Implementation of
Section titled “Implementation of”load()
Section titled “load()”load(
typeName):Promise<RememberEvent[]>
Defined in: src/cluster/sharding/RememberEntitiesStore.ts:64
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[]>