-
Notifications
You must be signed in to change notification settings - Fork 2
es cqrs.EventStoreProvider
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
| Name | Type |
|---|---|
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)
| Name | Type |
|---|---|
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)
| Name | Type |
|---|---|
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
| Name | Type |
|---|---|
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()
| Name | Type |
|---|---|
aggregate |
Aggregate |
Promise<void>
packages/es-cqrs/src/interfaces/event-store-provider.ts:27
▸ saveSnapshot(aggregate): Promise<void>
Save a snapshot of an aggregate
| Name | Type |
|---|---|
aggregate |
EventSourcedAggregate |
Promise<void>