Class EventStore

In-memory event store that records bus events and broadcasts live updates.

Index

Constructors

Methods

getAllEvents getSize onLiveEvent

Constructors

constructor

new EventStore(bus: RaftEventBus, options: EventStoreOptions): EventStore
Subscribes to an event bus and starts buffering incoming events.
Parameters
- bus: RaftEventBus
  Source event bus.
- options: EventStoreOptions
  Retention configuration.
Returns EventStore
- Defined in packages/raft-core/src/events/EventStore.ts:24

Methods

getAllEvents

getAllEvents(): RaftEvent[]
Returns a copy of currently retained events.

Returns RaftEvent[]
- Defined in packages/raft-core/src/events/EventStore.ts:42

getSize

getSize(): number
Returns current number of retained events.

Returns number
- Defined in packages/raft-core/src/events/EventStore.ts:58

onLiveEvent

onLiveEvent(subscriber: (event: RaftEvent) => void): () => void
Subscribes to live appended events.
Parameters
- subscriber: (event: RaftEvent) => void
  Live event callback.
Returns () => void
Unsubscribe callback.
- Defined in packages/raft-core/src/events/EventStore.ts:52