io.eventuate

Interface EventuateAggregateStore

public interface EventuateAggregateStore

The reactive-style interface to the event store

Method Summary

Modifier and Type	Method and Description
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityWithMetadata<T>>	find(java.lang.Class<T> clasz, java.lang.String entityId)
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityWithMetadata<T>>	find(java.lang.Class<T> clasz, java.lang.String entityId, FindOptions findOptions)
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityWithMetadata<T>>	find(java.lang.Class<T> clasz, java.lang.String entityId, java.util.Optional<FindOptions> findOptions)
java.util.Optional<Snapshot>	possiblySnapshot(Aggregate aggregate, java.util.Optional<io.eventuate.common.id.Int128> snapshotVersion, java.util.List<EventWithMetadata> oldEvents, java.util.List<Event> newEvents) Possibly generate a snapshot
Aggregate	recreateFromSnapshot(java.lang.Class<?> clasz, Snapshot snapshot) Recreate an aggregate from a snapshot
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion>	save(java.lang.Class<T> clasz, java.util.List<Event> events) Save an aggregate in the event store
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion>	save(java.lang.Class<T> clasz, java.util.List<Event> events, java.util.Optional<SaveOptions> saveOptions)
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion>	save(java.lang.Class<T> clasz, java.util.List<Event> events, SaveOptions saveOptions)
java.util.concurrent.CompletableFuture<?>	subscribe(java.lang.String subscriberId, java.util.Map<java.lang.String,java.util.Set<java.lang.String>> aggregatesAndEvents, SubscriberOptions subscriberOptions, java.util.function.Function<DispatchedEvent<Event>,java.util.concurrent.CompletableFuture<?>> dispatch)
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion>	update(java.lang.Class<T> clasz, EntityIdAndVersion entityIdAndVersion, java.util.List<Event> events)
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion>	update(java.lang.Class<T> clasz, EntityIdAndVersion entityIdAndVersion, java.util.List<Event> events, java.util.Optional<UpdateOptions> updateOptions)
<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion>	update(java.lang.Class<T> clasz, EntityIdAndVersion entityIdAndVersion, java.util.List<Event> events, UpdateOptions updateOptions)

Method Detail

save

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion> save(java.lang.Class<T> clasz,
                                                                                         java.util.List<Event> events)

Save an aggregate in the event store

Type Parameters:

T - the type of the aggregate

Parameters:

clasz - the class of the aggregate

events - the events to save

Returns:

the id and version of the newly saved aggregate

save

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion> save(java.lang.Class<T> clasz,
                                                                                         java.util.List<Event> events,
                                                                                         SaveOptions saveOptions)

save

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion> save(java.lang.Class<T> clasz,
                                                                                         java.util.List<Event> events,
                                                                                         java.util.Optional<SaveOptions> saveOptions)

find

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityWithMetadata<T>> find(java.lang.Class<T> clasz,
                                                                                            java.lang.String entityId)

find

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityWithMetadata<T>> find(java.lang.Class<T> clasz,
                                                                                            java.lang.String entityId,
                                                                                            FindOptions findOptions)

find

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityWithMetadata<T>> find(java.lang.Class<T> clasz,
                                                                                            java.lang.String entityId,
                                                                                            java.util.Optional<FindOptions> findOptions)

update

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion> update(java.lang.Class<T> clasz,
                                                                                           EntityIdAndVersion entityIdAndVersion,
                                                                                           java.util.List<Event> events)

update

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion> update(java.lang.Class<T> clasz,
                                                                                           EntityIdAndVersion entityIdAndVersion,
                                                                                           java.util.List<Event> events,
                                                                                           UpdateOptions updateOptions)

update

<T extends Aggregate<T>> java.util.concurrent.CompletableFuture<EntityIdAndVersion> update(java.lang.Class<T> clasz,
                                                                                           EntityIdAndVersion entityIdAndVersion,
                                                                                           java.util.List<Event> events,
                                                                                           java.util.Optional<UpdateOptions> updateOptions)

subscribe

java.util.concurrent.CompletableFuture<?> subscribe(java.lang.String subscriberId,
                                                    java.util.Map<java.lang.String,java.util.Set<java.lang.String>> aggregatesAndEvents,
                                                    SubscriberOptions subscriberOptions,
                                                    java.util.function.Function<DispatchedEvent<Event>,java.util.concurrent.CompletableFuture<?>> dispatch)

possiblySnapshot

java.util.Optional<Snapshot> possiblySnapshot(Aggregate aggregate,
                                              java.util.Optional<io.eventuate.common.id.Int128> snapshotVersion,
                                              java.util.List<EventWithMetadata> oldEvents,
                                              java.util.List<Event> newEvents)

Possibly generate a snapshot

Parameters:

aggregate - - the updated aggregate

snapshotVersion - - the version of the snapshot, if any, that the aggregate was created from

oldEvents - - the old events that were used to recreate the aggregate

newEvents - - the new events generated as a result of executing a command

Returns:

an optional snapshot

recreateFromSnapshot

Aggregate recreateFromSnapshot(java.lang.Class<?> clasz,
                               Snapshot snapshot)

Recreate an aggregate from a snapshot

Parameters:

clasz - the aggregate class

snapshot - the snapshot

Returns:

the aggregate