Package-level declarations
Types
Link copied to clipboard
class AggregateTracingHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy, admission: PointReadAdmission = PointReadAdmission.DISABLED) : HandlerFunction<ServerResponse>
Link copied to clipboard
class AggregateTracingHandlerFunctionFactory(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy, admission: PointReadAdmission = PointReadAdmission.DISABLED) : AggregateRouteHandlerFunctionFactorySupport
Link copied to clipboard
object AggregateTracingReplay
Link copied to clipboard
class LoadAggregateHandlerFunction(aggregateRouteMetadata: AggregateRouteMetadata<*>, stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED, route: StateLoadRoute = StateLoadRoute.LATEST) : HandlerFunction<ServerResponse>
Loads the state route names. A missing or deleted aggregate is 404; an owned aggregate is read only by its owner (OwnerAggregatePrecondition); under admission the state is admitted and masked as a query result is.
Link copied to clipboard
class LoadAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED, route: StateLoadRoute = StateLoadRoute.LATEST) : AggregateRouteHandlerFunctionFactorySupport
Link copied to clipboard
class PointReadAdmission(val enabled: Boolean = false, queryRequestScope: QueryRequestScope = DefaultQueryRequestScope, val tracingMaxVersions: Int = DEFAULT_TRACING_MAX_VERSIONS, policies: List<QueryPolicy> = emptyList(), snapshotSchema: (AggregateMetadata<*, *>) -> Mono<QueryModelSchema>? = null, eventStreamSchema: (AggregateMetadata<*, *>) -> Mono<QueryModelSchema>? = null, entryPolicy: QueryEntryPolicy = QueryEntryPolicy.DEFAULT)
Optional admission of state point reads: load by id, version or time, and tracing. They replay events and have no query AST, so the gateway never admits them.
Link copied to clipboard
The state load routes: each reads one point of an aggregate's history, named by its route.