io.eventuate.sync

Interface EventuateAggregateStore

public interface EventuateAggregateStore

The synchronous-style interface to the event store

Method Summary

Modifier and Type	Method and Description
<T extends Aggregate<T>> EntityWithMetadata<T>	find(java.lang.Class<T> clasz, java.lang.String entityId)
<T extends Aggregate<T>> EntityWithMetadata<T>	find(java.lang.Class<T> clasz, java.lang.String entityId, FindOptions findOptions)
<T extends Aggregate<T>> 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<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>> EntityIdAndVersion	save(java.lang.Class<T> clasz, java.util.List<Event> events)
<T extends Aggregate<T>> EntityIdAndVersion	save(java.lang.Class<T> clasz, java.util.List<Event> events, java.util.Optional<SaveOptions> saveOptions)
<T extends Aggregate<T>> EntityIdAndVersion	save(java.lang.Class<T> clasz, java.util.List<Event> events, SaveOptions saveOptions)
void	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>> EntityIdAndVersion	update(java.lang.Class<T> clasz, EntityIdAndVersion entityIdAndVersion, java.util.List<Event> events)
<T extends Aggregate<T>> EntityIdAndVersion	update(java.lang.Class<T> clasz, EntityIdAndVersion entityIdAndVersion, java.util.List<Event> events, java.util.Optional<UpdateOptions> updateOptions)
<T extends Aggregate<T>> EntityIdAndVersion	update(java.lang.Class<T> clasz, EntityIdAndVersion entityIdAndVersion, java.util.List<Event> events, UpdateOptions updateOptions)

Method Detail

save

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

save

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

save

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

find

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

find

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

find

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

update

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

update

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

update

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

subscribe

void 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<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