es cqrs.InmemoryEventStore

Class: InmemoryEventStore

es-cqrs.InmemoryEventStore

Default inmemory event-store implementation

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

Implements

• EventStoreProvider

Table of contents

Constructors

• constructor

Properties

• db
• options

Methods

• close
• getEvents
• getReplay
• getReplayCount
• getSnapshot
• init
• saveEvents
• saveSnapshot

Constructors

constructor

• new InmemoryEventStore(options): InmemoryEventStore

Parameters

Name	Type
options	EventStoreOptions

Returns

InmemoryEventStore

Defined in

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

Properties

db

• Private db: Object

Type declaration

Name	Type
events	Event[]
snapshots	EventSourcedAggregate[]

Defined in

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

---

options

• Private Readonly options: EventStoreOptions

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

Name	Type
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

Name	Type
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

Name	Type
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

Name	Type
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

Name	Type
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

Name	Type
aggregate	EventSourcedAggregate

Returns

Promise<void>

Implementation of

EventStoreProvider.saveSnapshot

Defined in

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