-
Notifications
You must be signed in to change notification settings - Fork 2
es cqrs.Interface.EventStoreProvider
@sclable/nestjs-libs / es-cqrs / EventStoreProvider
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:19
EventStore provider interface
The user is responsible for implementing this interface to provide an event-store. If it is ommited, the default
wolkenkit-eventstore will be used
close():
Promise<void>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:39
Close event-store
Promise<void>
getEvents(
aggregateId,fromRevision):Promise<Event[]>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:21
Get events for an aggregate
string
number
Promise<Event[]>
getReplay(
options?):Promise<Event[]>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:33
Get events to replay (default is all)
Promise<Event[]>
getReplayCount(
options?):Promise<number>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:35
Get count of events to replay (default is all)
Promise<number>
getSnapshot(
aggregateId):Promise<EventSourcedAggregate|undefined>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:29
Get the latest snapshot of an aggregate
string
Promise<EventSourcedAggregate | undefined>
init():
Promise<void>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:37
Init event-store
Promise<void>
saveEvents(
aggregate):Promise<void>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:27
Save events for an aggregate
Events are accessed through Aggregate.getUncommittedEvents()
Promise<void>
saveSnapshot(
aggregate):Promise<void>
Defined in: packages/es-cqrs/src/interfaces/event-store-provider.ts:31
Save a snapshot of an aggregate
EventSourcedAggregate
Promise<void>