Package org.axonframework.eventsourcing.eventstore
package org.axonframework.eventsourcing.eventstore
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
-
ClassDescriptionAbstractConsistencyMarker<T extends ConsistencyMarker>Abstract implementation of the
ConsistencyMarkerinterface that implements the required comparisons with theConsistencyMarker.ORIGINandConsistencyMarker.INFINITYconsistency markers.ConsistencyMarkerimplementation that keeps track of a position per aggregate identifier.Utility class for handling various operations related to the Aggregate-based Event Storage Engine.An implementation ofPositionbased on aggregate sequence numbers.Implementation ofTagResolverthat processesEventTagandEventTagsannotation on fields and methods of event payload objects to createTaginstances.Exception thrown when tag resolution fails.Interface describing the consistency boundary condition forEventMessageswhenappendingthem to an Event Store.Exception indicating that a transaction was rejected due to conflicts detected in the events to append.Interface representing a point in an Event Stream up to where certain state has been made up-to-date.AMessageStreamimplementation that continuously fetches event messages from a configurable data source.The defaultEventStoreTransaction.Represents an empty append transaction.Coordinates appended events notifications for event storage engines.Represents a handle to a coordination instance, allowing the engine to notify of new events and to terminate the coordination.Interface for providing storage engines for theStorageEngineBackedEventStore.Interface representing the transaction of an appendEvents invocation.Infrastructure component providing the means to start anEventStoreTransactiontoappend eventsandevent sourcemodels from the underlying storage solution.Indicates that the given events stream could not be stored or read due to an underlying exception.Interface describing the actions that can be taken on a transaction to source a model from theEventStorebased on the resultingMessageStream.GenericTaggedEventMessage<E extends EventMessage>ConsistencyMarkerimplementation that uses a single `long` to represent a position in an event stream.An immutable implementation ofPositionwhich represents positions with an index in the global event stream.Decorator around theEventStoreintercepting alleventsbefore they areappendedorpublishedwithdispatch interceptors.TagResolverthat combines the results of multiple other tag resolvers.Simple implementation of theTagResolverthat is able to combine several lambdas to constructTagsfrom payloads of typeP.Represents a position from which sourcing may start.Interface describing the condition tosourceevents from an Event Store.AnEventStoreimplementation which uses anEventStorageEngineas its storage solution.AnSpliterators.AbstractSpliteratorimplementation used internally to feed aStreamthrough theStreamSupport.stream(Spliterator, boolean)operation.TaggedEventMessage<E extends EventMessage>A wrapper of anEventMessageand itsTags.Exception indicating that an Event could not be appended to the event store because it contains more tags than the storage engine can support.