CassandraRememberEntitiesStore
Defined in: src/cluster/sharding/CassandraRememberEntitiesStore.ts:60
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.
Implements
Section titled “Implements”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new CassandraRememberEntitiesStore(
options):CassandraRememberEntitiesStore
Defined in: src/cluster/sharding/CassandraRememberEntitiesStore.ts:67
Parameters
Section titled “Parameters”options
Section titled “options”CassandraRememberEntitiesStoreOptions
Returns
Section titled “Returns”CassandraRememberEntitiesStore
Methods
Section titled “Methods”append()
Section titled “append()”append(
typeName,event):Promise<void>
Defined in: src/cluster/sharding/CassandraRememberEntitiesStore.ts:91
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/CassandraRememberEntitiesStore.ts:129
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”close()
Section titled “close()”close():
Promise<void>
Defined in: src/cluster/sharding/CassandraRememberEntitiesStore.ts:138
Returns
Section titled “Returns”Promise<void>
load()
Section titled “load()”load(
typeName):Promise<RememberEvent[]>
Defined in: src/cluster/sharding/CassandraRememberEntitiesStore.ts:114
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[]>
Implementation of
Section titled “Implementation of”start()
Section titled “start()”start():
Promise<void>
Defined in: src/cluster/sharding/CassandraRememberEntitiesStore.ts:73
Returns
Section titled “Returns”Promise<void>