Uses of Interface
org.axonframework.eventsourcing.eventstore.ConsistencyMarker
Packages that use ConsistencyMarker
Package
Description
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
-
Uses of ConsistencyMarker in org.axonframework.eventsourcing.eventstore
Classes in org.axonframework.eventsourcing.eventstore with type parameters of type ConsistencyMarkerModifier and TypeClassDescriptionclassAbstractConsistencyMarker<T extends ConsistencyMarker>Abstract implementation of theConsistencyMarkerinterface that implements the required comparisons with theORIGINandINFINITYconsistency markers.Classes in org.axonframework.eventsourcing.eventstore that implement ConsistencyMarkerModifier and TypeClassDescriptionclassAbstractConsistencyMarker<T extends ConsistencyMarker>Abstract implementation of theConsistencyMarkerinterface that implements the required comparisons with theORIGINandINFINITYconsistency markers.classConsistencyMarkerimplementation that keeps track of a position per aggregate identifier.classConsistencyMarkerimplementation that uses a single `long` to represent a position in an event stream.Fields in org.axonframework.eventsourcing.eventstore declared as ConsistencyMarkerModifier and TypeFieldDescriptionstatic final ConsistencyMarkerConsistencyMarker.INFINITYThe consistency marker representing the end of an event stream.static final ConsistencyMarkerConsistencyMarker.ORIGINThe consistency marker representing the start of an event stream.Fields in org.axonframework.eventsourcing.eventstore with type parameters of type ConsistencyMarkerModifier and TypeFieldDescriptionstatic final Context.ResourceKey<ConsistencyMarker> ConsistencyMarker.RESOURCE_KEYThe ResourceKey under which consistency markers are stored in aContext.Methods in org.axonframework.eventsourcing.eventstore that return ConsistencyMarkerModifier and TypeMethodDescriptionDefaultEventStoreTransaction.appendPosition()EventStoreTransaction.appendPosition()Returns the position in the event store of the lastappendedevent by this transaction.AppendCondition.consistencyMarker()Returns the position in the event store until which theEventsCondition.criteria()should be validated against.protected abstract ConsistencyMarkerAbstractConsistencyMarker.doLowerBound(T other) Calculate the lower bound ofthismarker and givenothermarker.protected ConsistencyMarkerGlobalIndexConsistencyMarker.doLowerBound(GlobalIndexConsistencyMarker other) protected abstract ConsistencyMarkerAbstractConsistencyMarker.doUpperBound(T other) Calculate the upper bound ofthismarker and givenothermarker.protected ConsistencyMarkerGlobalIndexConsistencyMarker.doUpperBound(GlobalIndexConsistencyMarker other) AbstractConsistencyMarker.lowerBound(ConsistencyMarker other) ConsistencyMarker.lowerBound(ConsistencyMarker other) Returns a ConsistencyMarker that represents the lower bound ofthisand givenothermarkers.AbstractConsistencyMarker.upperBound(ConsistencyMarker other) ConsistencyMarker.upperBound(ConsistencyMarker other) Returns a ConsistencyMarker that represents the upper bound ofthisand givenothermarkers.Methods in org.axonframework.eventsourcing.eventstore that return types with arguments of type ConsistencyMarkerModifier and TypeMethodDescriptionEmptyAppendTransaction.afterCommit(Void commitResult) Always provides the consistency markerORIGIN.EventStorageEngine.AppendTransaction.afterCommit(R commitResult) Returns aCompletableFutureto calculate the consistency marker.Methods in org.axonframework.eventsourcing.eventstore with parameters of type ConsistencyMarkerModifier and TypeMethodDescriptionstatic ContextConsistencyMarker.addToContext(Context context, ConsistencyMarker consistencyMarker) AppendEventsTransactionRejectedException.conflictingEventsDetected(ConsistencyMarker consistencyMarker) Constructs anAppendConditionAssertionExceptionnoting that theEventStorageEnginecontains events matching thecriteriapassed the givenconsistencyMarker.AbstractConsistencyMarker.lowerBound(ConsistencyMarker other) ConsistencyMarker.lowerBound(ConsistencyMarker other) Returns a ConsistencyMarker that represents the lower bound ofthisand givenothermarkers.static longGlobalIndexConsistencyMarker.position(ConsistencyMarker consistencyMarker) Utility function to resolve the position from givenconsistencyMarker.static ExceptionAggregateBasedEventStorageEngineUtils.translateConflictException(ConsistencyMarker consistencyMarker, Exception exception, Predicate<Throwable> isConflictException) Translates the givenExceptioninto anAppendEventsTransactionRejectedExceptionif it is identified as a conflict through the givenisConflictExceptionpredicate.static ThrowableAggregateBasedEventStorageEngineUtils.translateConflictException(ConsistencyMarker consistencyMarker, Throwable e, Predicate<Throwable> isConflictException) Translates the givenThrowableinto anAppendEventsTransactionRejectedExceptionif it is identified as a conflict through the givenisConflictExceptionpredicate.AbstractConsistencyMarker.upperBound(ConsistencyMarker other) ConsistencyMarker.upperBound(ConsistencyMarker other) Returns a ConsistencyMarker that represents the upper bound ofthisand givenothermarkers.AppendCondition.withMarker(ConsistencyMarker consistencyMarker) Creates an AppendCondition with the same criteria as this one, but with givenconsistencyMarker.