Uses of Interface
org.axonframework.eventsourcing.eventstore.ConsistencyMarker

Packages that use ConsistencyMarker

Package	Description
io.axoniq.framework.workflow.runtime.api.execution.context	Internal runtime contracts for workflow execution, command dispatch, configuration, and event publication.
io.axoniq.framework.workflow.runtime.execution	Internal implementation of the workflow execution engine: the WorkflowEngine, its scheduling, state and storage, checkpointing/replay support, cancellation coordination, and the delegates implementing individual step primitives.
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.

Uses of ConsistencyMarker in io.axoniq.framework.workflow.runtime.api.execution.context

Methods in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type ConsistencyMarker

Modifier and Type	Method	Description
void	WorkflowExecution.restoreAppendPosition(@Nullable ConsistencyMarker position)	Restores the position from which this execution conditions its next append.

Uses of ConsistencyMarker in io.axoniq.framework.workflow.runtime.execution

Methods in io.axoniq.framework.workflow.runtime.execution with parameters of type ConsistencyMarker

Modifier and Type	Method	Description
void	SimpleWorkflowExecution.restoreAppendPosition(@Nullable ConsistencyMarker position)

Uses of ConsistencyMarker in org.axonframework.eventsourcing.eventstore

Classes in org.axonframework.eventsourcing.eventstore with type parameters of type ConsistencyMarker

Modifier and Type	Class	Description
class	AbstractConsistencyMarker<T extends ConsistencyMarker>	Abstract implementation of the ConsistencyMarker interface that implements the required comparisons with the ORIGIN and INFINITY consistency markers.

Classes in org.axonframework.eventsourcing.eventstore that implement ConsistencyMarker

Modifier and Type	Class	Description
class	AbstractConsistencyMarker<T extends ConsistencyMarker>	Abstract implementation of the ConsistencyMarker interface that implements the required comparisons with the ORIGIN and INFINITY consistency markers.
class	AggregateBasedConsistencyMarker	ConsistencyMarker implementation that keeps track of a position per aggregate identifier.
class	GlobalIndexConsistencyMarker	ConsistencyMarker implementation that uses a single `long` to represent a position in an event stream.

Fields in org.axonframework.eventsourcing.eventstore declared as ConsistencyMarker

Modifier and Type	Field	Description
static final ConsistencyMarker	ConsistencyMarker.INFINITY	The consistency marker representing the end of an event stream.
static final ConsistencyMarker	ConsistencyMarker.ORIGIN	The consistency marker representing the start of an event stream.

Fields in org.axonframework.eventsourcing.eventstore with type parameters of type ConsistencyMarker

Modifier and Type	Field	Description
static final Context.ResourceKey<ConsistencyMarker>	ConsistencyMarker.RESOURCE_KEY	The ResourceKey under which consistency markers are stored in a Context.

Methods in org.axonframework.eventsourcing.eventstore that return ConsistencyMarker

Modifier and Type	Method	Description
ConsistencyMarker	DefaultEventStoreTransaction.appendPosition()
ConsistencyMarker	EventStoreTransaction.appendPosition()	Returns the position in the event store of the last appended event by this transaction.
ConsistencyMarker	AppendCondition.consistencyMarker()	Returns the position in the event store until which the EventsCondition.criteria() should be validated against.
protected abstract ConsistencyMarker	AbstractConsistencyMarker.doLowerBound(T other)	Calculate the lower bound of this marker and given other marker.
protected ConsistencyMarker	GlobalIndexConsistencyMarker.doLowerBound(GlobalIndexConsistencyMarker other)
protected abstract ConsistencyMarker	AbstractConsistencyMarker.doUpperBound(T other)	Calculate the upper bound of this marker and given other marker.
protected ConsistencyMarker	GlobalIndexConsistencyMarker.doUpperBound(GlobalIndexConsistencyMarker other)
ConsistencyMarker	AbstractConsistencyMarker.lowerBound(ConsistencyMarker other)
ConsistencyMarker	ConsistencyMarker.lowerBound(ConsistencyMarker other)	Returns a ConsistencyMarker that represents the lower bound of this and given other markers.
ConsistencyMarker	AbstractConsistencyMarker.upperBound(ConsistencyMarker other)
ConsistencyMarker	ConsistencyMarker.upperBound(ConsistencyMarker other)	Returns a ConsistencyMarker that represents the upper bound of this and given other markers.

Methods in org.axonframework.eventsourcing.eventstore that return types with arguments of type ConsistencyMarker

Modifier and Type	Method	Description
CompletableFuture<ConsistencyMarker>	EmptyAppendTransaction.afterCommit(@Nullable Void commitResult)	Always provides the consistency marker ORIGIN.
CompletableFuture<ConsistencyMarker>	EventStorageEngine.AppendTransaction.afterCommit(R commitResult)	Returns a CompletableFuture to calculate the consistency marker.

Methods in org.axonframework.eventsourcing.eventstore with parameters of type ConsistencyMarker

Modifier and Type	Method	Description
static Context	ConsistencyMarker.addToContext(Context context, ConsistencyMarker consistencyMarker)	Adds the given consistencyMarker to the given context using the RESOURCE_KEY.
static AppendEventsTransactionRejectedException	AppendEventsTransactionRejectedException.conflictingEventsDetected(ConsistencyMarker consistencyMarker)	Constructs an AppendEventsTransactionRejectedException noting that the EventStorageEngine contains events matching the criteria passed the given consistencyMarker.
static AppendEventsTransactionRejectedException	AppendEventsTransactionRejectedException.conflictingEventsDetected(ConsistencyMarker consistencyMarker, Set<Tag> tags)	Constructs an AppendEventsTransactionRejectedException noting that the EventStorageEngine contains events matching the criteria passed the given consistencyMarker.
ConsistencyMarker	AbstractConsistencyMarker.lowerBound(ConsistencyMarker other)
ConsistencyMarker	ConsistencyMarker.lowerBound(ConsistencyMarker other)	Returns a ConsistencyMarker that represents the lower bound of this and given other markers.
static long	GlobalIndexConsistencyMarker.position(ConsistencyMarker consistencyMarker)	Utility function to resolve the position from given consistencyMarker.
static Exception	AggregateBasedEventStorageEngineUtils.translateConflictException(ConsistencyMarker consistencyMarker, Exception exception, Predicate<Throwable> isConflictException)	Translates the given Exception into an AppendEventsTransactionRejectedException if it is identified as a conflict through the given isConflictException predicate.
static Throwable	AggregateBasedEventStorageEngineUtils.translateConflictException(ConsistencyMarker consistencyMarker, Throwable e, Predicate<Throwable> isConflictException)	Translates the given Throwable into an AppendEventsTransactionRejectedException if it is identified as a conflict through the given isConflictException predicate.
ConsistencyMarker	AbstractConsistencyMarker.upperBound(ConsistencyMarker other)
ConsistencyMarker	ConsistencyMarker.upperBound(ConsistencyMarker other)	Returns a ConsistencyMarker that represents the upper bound of this and given other markers.
AppendCondition	AppendCondition.withMarker(ConsistencyMarker consistencyMarker)	Creates an AppendCondition with the same criteria as this one, but with given consistencyMarker.