es cqrs.Class.InmemoryEventStore

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

Class: InmemoryEventStore

Defined in: packages/es-cqrs/src/event-store/inmemory-event-store.ts:44

Default inmemory event-store implementation

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

Implements

• EventStoreProvider

Constructors

Constructor

new InmemoryEventStore(options): InmemoryEventStore

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

Parameters

options

EventStoreOptions

Returns

InmemoryEventStore

Methods

close()

close(): Promise<void>

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

Close event-store

Returns

Promise<void>

Implementation of

EventStoreProvider.close

---

getEvents()

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

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

Get events for an aggregate

Parameters

aggregateId

string

fromRevision

number

Returns

Promise<Event[]>

Implementation of

EventStoreProvider.getEvents

---

getReplay()

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

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

Get events to replay (default is all)

Parameters

options?

ReplayOptions

Returns

Promise<Event[]>

Implementation of

EventStoreProvider.getReplay

---

getReplayCount()

getReplayCount(options?): Promise<number>

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

Get count of events to replay (default is all)

Parameters

options?

ReplayOptions

Returns

Promise<number>

Implementation of

EventStoreProvider.getReplayCount

---

getSnapshot()

getSnapshot(aggregateId): Promise<EventSourcedAggregate | undefined>

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

Get the latest snapshot of an aggregate

Parameters

aggregateId

string

Returns

Promise<EventSourcedAggregate | undefined>

Implementation of

EventStoreProvider.getSnapshot

---

init()

init(): Promise<void>

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

Init event-store

Returns

Promise<void>

Implementation of

EventStoreProvider.init

---

saveEvents()

saveEvents(aggregate): Promise<void>

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

Save events for an aggregate

Events are accessed through Aggregate.getUncommittedEvents()

Parameters

aggregate

Aggregate

Returns

Promise<void>

Implementation of

EventStoreProvider.saveEvents

---

saveSnapshot()

saveSnapshot(aggregate): Promise<void>

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

Save a snapshot of an aggregate

Parameters

aggregate

EventSourcedAggregate

Returns

Promise<void>

Implementation of

EventStoreProvider.saveSnapshot