All Classes and Interfaces

Class	Description
AbstractEventDataMarshallingEventUpcaster	Template implementation of EventUpcaster that uses a delegate EventDataMarshaller to allow subclasses to upcast EventData.metaData() and EventData.payload() as pre-extracted JSON-like Maps.
AbstractEventDataMarshallingEventUpcaster.MetaDataAndPayloadResult	Captures upcasted Event.type(), meta-data, and payload.
AutowiredParameter	Represents an Autowired parameter within an annotated handler definition.
AutowiredParameterResolver	Base class for reflective AutowiredParameter resolution.
BackOff	Interface to be implemented by classes providing back off semantics, e.g.
BackOff.Execution	Encapsulates back off execution state.
CapturedEvent	Record capturing an event publication intent.
ClassNameEventTypeResolver	EventTypeResolver implementation that maps Class.getName() to event type and vice versa.
ClassNameEventTypeResolverAutoConfiguration	Auto-configuration for ClassNameEventTypeResolver.
ClientException	Base class for an exception thrown from EsdbClient.
ClientException.HttpException	Base class for exceptions related to HTTP status codes returned from an event store.
ClientException.HttpException.HttpClientException	Exception class thrown for HTTP status codes 4xx.
ClientException.HttpException.HttpServerException	Exception class thrown for HTTP status codes 5xx.
ClientException.InterruptedException	Exception class representing thread interruption.
ClientException.InvalidUsageException	Exception class representing errors due to invalid client API usage.
ClientException.MarshallingException	Exception class thrown by Marshaller implementations due to serialization or deserialization errors.
ClientException.TransportException	Exception class representing network and/or connection errors.
ClientInterruptedException	Exception class representing thread interruption signalled by ClientException.InterruptedException.
ClientRequestErrorMapper	Helper class to map errors from EsdbClient operations to CqrsFrameworkException.
Command	Interface to be implemented by commands that can be handled by CommandHandlers.
Command.SubjectCondition	The subject condition checked before CommandHandler execution.
CommandEventCapturer<I>	Default implementation of CommandEventPublisher used by CommandRouter to apply events to the StateRebuildingHandlers relevant for the Command being executed.
CommandEventPublisher<I>	Extension to EventPublisher providing additional operations for publishing events relative to the Command.getSubject() being handled.
CommandHandler<I,C,R>	Sealed base interface for inherited FunctionalInterface variants encapsulating command-handling logic.
CommandHandler.ForCommand<I,C,R>	FunctionalInterface to be implemented, if only the Command is needed for execution.
CommandHandler.ForInstanceAndCommand<I,C,R>	FunctionalInterface to be implemented, if Command and event-sourced instance are needed for execution.
CommandHandler.ForInstanceAndCommandAndMetaData<I,C,R>	FunctionalInterface to be implemented, if Command, meta-data, and event-sourced instance are needed for execution.
CommandHandlerConfiguration	Annotation to be used for Configurations containing CommandHandling annotated methods, CommandHandlerDefinition Beans, @StateRebuilding annotated methods, and StateRebuildingHandlerDefinition Beans in order to be able to test them using CommandHandlingTest.
CommandHandlerDefinition<I,C,R>	CommandHandler definition suitable for being processed by the CommandRouter.
CommandHandling	Annotation to be used in favor of defining CommandHandlerDefinition Beans.
CommandHandlingAnnotationProcessingAutoConfiguration	Auto-configuration for CommandHandlerDefinitions defined via CommandHandling annotated bean methods.
CommandHandlingCacheProperties	ConfigurationProperties for auto-configured StateRebuildingCaches.
CommandHandlingCacheProperties.Type	The pre-defined cache type.
CommandHandlingTest	Annotation that can be used for Spring Boot tests that focus only on CQRS CommandHandlerDefinitions in favor of initializing CommandHandlingTestFixture manually.
CommandHandlingTestAutoConfiguration	Auto-configuration for CommandHandlingTestFixtures.
CommandHandlingTestFixture<I,C,R>	Test support for CommandHandler or CommandHandlerDefinition.
CommandHandlingTestFixture.Builder<I>	Builder for CommandHandlingTestFixture.
CommandHandlingTestFixture.EventAsserter	Fluent API helper class for asserting a captured events.
CommandHandlingTestFixture.Expect.StatefulAssertion	Marker annotation for assertion methods within CommandHandlingTestFixture.Expect which proceed through the captured event stream, if invoked.
CommandHandlingTestFixture.Given.GivenEvent<I>	Fluent API helper class for fine granular specification of a single given event.
CommandRouter	Command router implementation providing CQRS-style command execution.
CommandRouterAutoConfiguration	Auto-configuration for CommandRouter and StateRebuildingCache default implementations.
CommandSubjectAlreadyExistsException	Exception thrown if Command.SubjectCondition.PRISTINE is violated.
CommandSubjectConditionViolatedException	Exception thrown if Command.SubjectCondition is violated.
CommandSubjectDoesNotExistException	Exception thrown if Command.SubjectCondition.EXISTS is violated.
ConcurrencyException	Exception class representing concurrency errors, usually caused by violated preconditions, when publishing events.
CqrsFrameworkException	Base class for exceptions handled within the framework.
CqrsFrameworkException.NonTransientException	Exception class representing non-recoveralbe errors.
CqrsFrameworkException.TransientException	Exception class representing potentially recoverable errors, such as communication or concurrency errors.
DefaultPartitionKeyResolver	Default implementation of PartitionKeyResolver which uses CRC32 checksums and modulo operation to derive partition numbers from event sequence identifiers.
ErrorHandler	Callback interface that needs to be implement for receiving errors from calls to EsdbClient.query(String, RowHandler, ErrorHandler).
EsdbClient	Client SDK for the EventSourcingDB.
EsdbClientAutoConfiguration	Auto-configuration for EsdbClient.
EsdbHealthContributorAutoConfiguration	Auto-configuration for EsdbHealthIndicator.
EsdbHealthIndicator	HealthContributor implementation based on EsdbClient.health().
EsdbProperties	ConfigurationProperties for auto-configured EsdbClient.
EsdbProperties.Server	Server configuration settings.
Event	Event data structure retrieved from an event store, conforming to the Cloud Events Specification.
EventCandidate	Candidate event for publication to a Cloud Events Specification conforming event store.
EventCapturer	In-memory implementation of EventPublisher using CapturedEvents.
EventData<E>	Represents unmarshalled EventCandidate.data() or Event.data(), respectively.
EventDataMarshaller	Interface implemented for transforming Java event objects and additional meta-data to JSON-like maps, and vice versa.
EventHandler<E>	Sealed base interface for inherited FunctionalInterface variants encapsulating encapsulating Event handling logic.
EventHandler.ForObject<E>	FunctionalInterface to be implemented, if only the Java event is needed for processing.
EventHandler.ForObjectAndMetaData<E>	FunctionalInterface to be implemented, if the Java event and its meta-data is needed for processing.
EventHandler.ForObjectAndMetaDataAndRawEvent<E>	FunctionalInterface to be implemented, if the Java event, its meta-data, and the raw event is needed for processing.
EventHandlerDefinition<E>	EventHandler definition suitable for being processed by an event processor.
EventHandling	Annotation to be used in favor of defining EventHandlerDefinition Beans.
EventHandlingAnnotationProcessingAutoConfiguration	Auto-configuration for EventHandlerDefinitions defined via EventHandling annotated bean methods.
EventHandlingProcessor	Asynchronous event processor observing an event stream to be handled by matching EventHandlerDefinitions all belonging to the same processing group and partition with configurable progress tracking and retry in case of errors.
EventHandlingProcessorAutoConfiguration	Auto-configuration for EventHandlingProcessor and supporting beans.
EventHandlingProcessorAutoConfiguration.LeaderElectionLifecycleConfiguration
EventHandlingProcessorAutoConfiguration.LeaderElectionLifecycleConfiguration.Registration
EventHandlingProcessorLifecycleController	Interface to be implemented by beans responsible for managing the life-cycle of an EventHandlingProcessor bean.
EventHandlingProcessorLifecycleRegistration	Interface to be implemented for registering EventHandlingProcessorLifecycleController beans.
EventHandlingProperties	ConfigurationProperties for auto-configured EventHandlingProcessors.
EventHandlingProperties.ProcessorSettings	Configuration settings for an instance of EventHandlingProcessor.
EventHandlingProperties.ProcessorSettings.Fetch	Configures event stream fetching.
EventHandlingProperties.ProcessorSettings.LifeCycle	Configures life-cycle registration.
EventHandlingProperties.ProcessorSettings.LifeCycle.Controller	The built-in EventHandlingProcessorLifecycleController type.
EventHandlingProperties.ProcessorSettings.Progress	Configures which ProgressTracker to use.
EventHandlingProperties.ProcessorSettings.Progress.Tracker	The built-in ProgressTracker type.
EventHandlingProperties.ProcessorSettings.Retry	Error handling retry configuration settings.
EventHandlingProperties.ProcessorSettings.Retry.Policy	The back-off policy.
EventHandlingProperties.ProcessorSettings.Sequencing	Configures which EventSequenceResolver to use.
EventHandlingProperties.ProcessorSettings.Sequencing.Resolution	The built-in EventSequenceResolver type.
EventPersistenceAutoConfiguration	Auto-configuration for EventRepository and EventSource.
EventPublisher	Interface specifying operations for publishing Java event objects.
EventReader	Interface specifying operations for reading events from an EsdbClient.
EventReader.ClientRequestor	Generically wraps EsdbClient calls to consume Events.
EventReader.RawCallback	Callback interface specifying operations to deal with an encapsulated raw Event.
EventReader.UpcastedCallback	Callback interface specifying operations to deal with an encapsulated upcasted Event.
EventRepository	Default implementation of EventReader and ImmediateEventPublisher.
EventSequenceResolver<E>	Sealed base interface for inherited FunctionalInterface variants encapsulating the logic to derive a sequence identifier for an event.
EventSequenceResolver.ForObjectAndMetaDataAndRawEvent<E>	FunctionalInterface to be implemented, if an event's sequence identifier can only be derived from a fully upcasted and deserialized Java event object.
EventSequenceResolver.ForRawEvent	FunctionalInterface to be implemented, if an event's sequence identifier can be derived from a raw Event, that is without any upcasting or Java object deserialization.
EventSource	Encapsulates a configurable Event.source() for event publication.
EventTypeResolutionException	CqrsFrameworkException.NonTransientException exception capturing an EventTypeResolver resolution error.
EventTypeResolver	Interface implemented for resolving Java Class to EventCandidate.type() or Event.type() and vice versa.
EventUpcaster	Interface to be implemented when Events need to be migrated to a new representation, so-called upcasting.
EventUpcaster.Result	Captures upcasted Event.type() and Event.data().
EventUpcasterAutoConfiguration	Auto-configuration for EventUpcasters.
EventUpcasters	Implementation class delegating to a list of configurable EventUpcasters combining the EventUpcaster.Results appropriately.
Health	Represents the current health status of the configured ESDB.
Health.Status	Health status.
IdUtil	Static helper methods related to Event.id().
ImmediateEventPublisher	Interface specifying operations for immediate, atomic event publication.
InMemoryProgressTracker	ProgressTracker implementation using an in-memory Map.
JacksonEventDataMarshaller	EventDataMarshaller implementation that uses a configurable ObjectMapper for marshalling.
JacksonEventDataMarshallerAutoConfiguration	Auto-configuration for JacksonEventDataMarshaller.
JacksonMarshaller	ObjectMapper based Marshaller implementation.
JacksonMarshallerAutoConfiguration	Auto-configuration for JacksonMarshaller.
JdbcProgressTracker	ProgressTracker implementation using Spring JdbcOperations and TransactionOperations to persist Progress.
LruInMemoryStateRebuildingCache	StateRebuildingCache implementation backed by a synchronized LinkedHashMap with configurable maximum capacity and LRU semantics.
Marshaller	Interface specifying operations for HTTP request/response marshalling.
Marshaller.QueryResponseElement	Sealed interface representing a deserialized ND-JSON response line transformed via Marshaller.fromQueryResponseLine(String).
Marshaller.QueryResponseElement.Error	Represents an error returned from the event store, typically caused by an invalid query or missing data in the result set.
Marshaller.QueryResponseElement.Row	Represents a row returned from the event store, which may be processed by the deferred BiConsumer.
Marshaller.ResponseElement	Sealed interface representing a deserialized ND-JSON response line transformed via Marshaller.fromReadOrObserveResponseLine(String).
Marshaller.ResponseElement.Heartbeat	Represents a heart beat returned from the event store to ensure the underlying HTTP connection is kept alive.
MetaDataPropagationProperties	ConfigurationProperties for auto-configured CommandRouter meta-data propagation.
NoEventSequenceResolver	EventSequenceResolver.ForRawEvent implementation to be used if no event sequencing is required, i.e.
NoEventUpcaster	EventUpcaster implementation that drops an Event if the Event.type() matches the configured type.
NoStateRebuildingCache	StateRebuildingCache implementation that does not cache anything.
NoTransactionOperationsAdapter	Implementation of TransactionOperationsAdapter used if Spring TX is not available on the class-path or EventHandling methods have not been annotated using Transactional.
Option	Sealed interface for options used by EsdbClient to read or observe events from the underlying event store.
Option.FromLatestEvent	Specifies that the list of events is optimized by omitting any event prior to the latest event available for the subject specified as part of this.
Option.FromLatestEvent.IfEventIsMissing	Specifies the fall-back fetch strategy.
Option.LowerBoundExclusive	Specifies the lowest exclusive event id to fetch from.
Option.LowerBoundInclusive	Specifies the lowest inclusive event id to fetch from.
Option.Order	Encapsulates the type of ordering of the fetched events.
Option.Order.Type	Specifies the event order.
Option.Recursive	Specifies that events shall be fetched recursively, that is including the requested subject (events) and its hierarchical subject (events).
Option.UpperBoundExclusive	Specifies the highest exclusive event id to fetch to.
Option.UpperBoundInclusive	Specifies the highest inclusive event id to fetch to.
PartitionKeyResolver	Interface for implementations able to derive a consistently derive a numeric partition key from an event sequence identifier.
PerConfigurableLevelSubjectEventSequenceResolver	EventSequenceResolver.ForRawEvent implementation which reduced the Event.subject() path and reduces it to a configurable level, i.e.
PerSubjectEventSequenceResolver	EventSequenceResolver.ForRawEvent implementation which uses Event.subject() as the event sequence identifier.
Precondition	Sealed interface for preconditions used for event publication to ensure consistency within the underlying event store.
Precondition.SubjectIsOnEventId	A precondition stating the given subject must have been updated by the given event id.
Precondition.SubjectIsPristine	A precondition stating the given subject must not yet exist within the event store.
PreconfiguredAssignableClassEventTypeResolver	EventTypeResolver implementation that can be pre-configured using a specific mapping between event types and Java classes.
Progress	Sealed interface for subclasses representing the progress of event handling the event stream for a processing group.
Progress.None	States no progress for the event processing group is known.
Progress.Success	Represents the last Event.id() that has been successfully processed by the event processing group.
ProgressTracker	Interface specifying operations for tracking progress of event processing groups.
PropagationMode	Specifies how meta-data is going to be propagated from source (for instance command meta-data) to destination (for instance published event meta-data).
PropagationUtil	Util class for meta-data propagation.
QueryProcessingError	Encapsulates a query processing error caused by EsdbClient.query(String, RowHandler, ErrorHandler).
QueryProcessingError.Token	Encapsulates a token describing the error position within a malformed or unprocessable query.
RowHandler	Sealed base interface for handlers capable of processing query result rows.
RowHandler.AsEvent	FunctionalInterface to be implemented for consuming query result rows as Event.
RowHandler.AsMap	FunctionalInterface to be implemented for consuming query result rows as JSON maps.
RowHandler.AsObject<T>	Interface to be implemented for consuming query result rows as JSON objects.
RowHandler.AsScalar<T>	FunctionalInterface to be implemented for consuming query result rows as scalar data types.
SourcingMode	The type of sourcing affecting which events will be sourced for CommandHandlers.
SpringTransactionOperationsAdapter	TransactionOperationsAdapter implementation that uses a TransactionOperations delegate for transactional execution of an EventHandling annotated method according to the supplied Transactional configuration.
StateRebuilding	Annotation to be used in favor of defining StateRebuildingHandlerDefinition Beans.
StateRebuildingAnnotationProcessingAutoConfiguration	Auto-configuration for StateRebuildingHandlerDefinitions defined via StateRebuilding annotated bean methods.
StateRebuildingCache	Interface specifying operations to cache event-sourced instance state to reduce the number of fetched events prior to executing a CommandHandler.
StateRebuildingCache.CacheKey<I>	Represents the cache key, whose equality determines, which StateRebuildingCache.CacheValue to fetch.
StateRebuildingCache.CacheValue<I>	Represents the cache value.
StateRebuildingHandler<I,E>	Sealed base interface for inherited FunctionalInterface variants encapsulating the event-sourcing logic needed to reconstruct instance state from an event stream.
StateRebuildingHandler.FromObject<I,E>	FunctionalInterface to be implemented, if only the Java event is needed to reconstruct the instance state.
StateRebuildingHandler.FromObjectAndMetaData<I,E>	FunctionalInterface to be implemented, if the Java event and its meta-data is needed to reconstruct the instance state.
StateRebuildingHandler.FromObjectAndMetaDataAndSubject<I,E>	FunctionalInterface to be implemented, if the Java event, its meta-data, and subject is needed to reconstruct the instance state.
StateRebuildingHandler.FromObjectAndMetaDataAndSubjectAndRawEvent<I,E>	FunctionalInterface to be implemented, if the Java event, its meta-data, subject, and optional raw event is needed to reconstruct the instance state.
StateRebuildingHandler.FromObjectAndRawEvent<I,E>	FunctionalInterface to be implemented, if the Java event and the raw Event is needed to reconstruct the instance state.
StateRebuildingHandlerDefinition<I,E>	StateRebuildingHandler definition suitable for event-sourcing an instance prior to command handling.
TransactionOperationsAdapter	Internal interface encapsulating Transactional method execution.
TypeChangingEventUpcaster	EventUpcaster implementation that changes the Event.type() to a new type if it matches the configured source type.