-
Notifications
You must be signed in to change notification settings - Fork 2
es cqrs.Class.InmemoryEventStore
@sclable/nestjs-libs / es-cqrs / 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
new InmemoryEventStore(
options):InmemoryEventStore
Defined in: packages/es-cqrs/src/event-store/inmemory-event-store.ts:46
InmemoryEventStore
close():
Promise<void>
Defined in: packages/es-cqrs/src/event-store/inmemory-event-store.ts:93
Close event-store
Promise<void>
getEvents(
aggregateId,fromRevision):Promise<Event[]>
Defined in: packages/es-cqrs/src/event-store/inmemory-event-store.ts:52
Get events for an aggregate
string
number
Promise<Event[]>
getReplay(
options?):Promise<Event[]>
Defined in: packages/es-cqrs/src/event-store/inmemory-event-store.ts:76
Get events to replay (default is all)
Promise<Event[]>
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)
Promise<number>
EventStoreProvider.getReplayCount
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
string
Promise<EventSourcedAggregate | undefined>
EventStoreProvider.getSnapshot
init():
Promise<void>
Defined in: packages/es-cqrs/src/event-store/inmemory-event-store.ts:90
Init event-store
Promise<void>
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()
Promise<void>
saveSnapshot(
aggregate):Promise<void>
Defined in: packages/es-cqrs/src/event-store/inmemory-event-store.ts:67
Save a snapshot of an aggregate
EventSourcedAggregate
Promise<void>