es cqrs.Class.InmemoryEventStore

@sclable/nestjs-libs / es-cqrs / InmemoryEventStore

Class: InmemoryEventStore

Default inmemory event-store implementation

Simplified version of inmemory wolkenkit-eventstore to demonstrate implementing a custom event-store

Implements

• EventStoreProvider

Constructors

new InmemoryEventStore()

new InmemoryEventStore(options): InmemoryEventStore

Parameters

• options: EventStoreOptions

Returns

InmemoryEventStore

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:46

Methods

close()

close(): Promise<void>

Close event-store

Returns

Promise<void>

Implementation of

EventStoreProvider.close

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:93

---

getEvents()

getEvents(aggregateId, fromRevision): Promise<Event[]>

Get events for an aggregate

Parameters

• aggregateId: string

• fromRevision: number

Returns

Promise<Event[]>

Implementation of

EventStoreProvider.getEvents

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:52

---

getReplay()

getReplay(options?): Promise<Event[]>

Get events to replay (default is all)

Parameters

• options?: ReplayOptions

Returns

Promise<Event[]>

Implementation of

EventStoreProvider.getReplay

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:76

---

getReplayCount()

getReplayCount(options?): Promise<number>

Get count of events to replay (default is all)

Parameters

• options?: ReplayOptions

Returns

Promise<number>

Implementation of

EventStoreProvider.getReplayCount

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:83

---

getSnapshot()

getSnapshot(aggregateId): Promise<undefined | EventSourcedAggregate>

Get the latest snapshot of an aggregate

Parameters

• aggregateId: string

Returns

Promise<undefined | EventSourcedAggregate>

Implementation of

EventStoreProvider.getSnapshot

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:61

---

init()

init(): Promise<void>

Init event-store

Returns

Promise<void>

Implementation of

EventStoreProvider.init

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:90

---

saveEvents()

saveEvents(aggregate): Promise<void>

Save events for an aggregate

Events are accessed through Aggregate.getUncommittedEvents()

Parameters

• aggregate: Aggregate

Returns

Promise<void>

Implementation of

EventStoreProvider.saveEvents

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:57

---

saveSnapshot()

saveSnapshot(aggregate): Promise<void>

Save a snapshot of an aggregate

Parameters

• aggregate: EventSourcedAggregate

Returns

Promise<void>

Implementation of

EventStoreProvider.saveSnapshot

Defined in

packages/es-cqrs/src/event-store/inmemory-event-store.ts:67