-
Notifications
You must be signed in to change notification settings - Fork 2
es cqrs.Interface.EventStoreProvider
@sclable/nestjs-libs / es-cqrs / EventStoreProvider
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>
Close event-store
Promise<void>
packages/es-cqrs/src/interfaces/event-store-provider.ts:39
getEvents(
aggregateId,fromRevision):Promise<Event[]>
Get events for an aggregate
• aggregateId: string
• fromRevision: number
Promise<Event[]>
packages/es-cqrs/src/interfaces/event-store-provider.ts:21
getReplay(
options?):Promise<Event[]>
Get events to replay (default is all)
• options?: ReplayOptions
Promise<Event[]>
packages/es-cqrs/src/interfaces/event-store-provider.ts:33
getReplayCount(
options?):Promise<number>
Get count of events to replay (default is all)
• options?: ReplayOptions
Promise<number>
packages/es-cqrs/src/interfaces/event-store-provider.ts:35
getSnapshot(
aggregateId):Promise<undefined|EventSourcedAggregate>
Get the latest snapshot of an aggregate
• aggregateId: string
Promise<undefined | EventSourcedAggregate>
packages/es-cqrs/src/interfaces/event-store-provider.ts:29
init():
Promise<void>
Init event-store
Promise<void>
packages/es-cqrs/src/interfaces/event-store-provider.ts:37
saveEvents(
aggregate):Promise<void>
Save events for an aggregate
Events are accessed through Aggregate.getUncommittedEvents()
• aggregate: Aggregate
Promise<void>
packages/es-cqrs/src/interfaces/event-store-provider.ts:27
saveSnapshot(
aggregate):Promise<void>
Save a snapshot of an aggregate
• aggregate: EventSourcedAggregate
Promise<void>