wow-webflux/me.ahoo.wow.webflux.route.state

Package-level declarations

Types

abstract class AbstractLoadAggregateHandlerFunction(aggregateRouteMetadata: AggregateRouteMetadata<*>, stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED) : HandlerFunction<ServerResponse>

AggregateTracingHandlerFunction

class AggregateTracingHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy, admission: PointReadAdmission = PointReadAdmission.DISABLED) : HandlerFunction<ServerResponse>

AggregateTracingHandlerFunctionFactory

class AggregateTracingHandlerFunctionFactory(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy, admission: PointReadAdmission = PointReadAdmission.DISABLED) : AggregateRouteHandlerFunctionFactorySupport

AggregateTracingReplay

object AggregateTracingReplay

LoadAggregateHandlerFunction

class LoadAggregateHandlerFunction(aggregateRouteMetadata: AggregateRouteMetadata<*>, stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED) : AbstractLoadAggregateHandlerFunction

LoadAggregateHandlerFunctionFactory

class LoadAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED) : AggregateRouteHandlerFunctionFactorySupport

LoadTimeBasedAggregateHandlerFunction

class LoadTimeBasedAggregateHandlerFunction(aggregateRouteMetadata: AggregateRouteMetadata<*>, stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED) : HandlerFunction<ServerResponse>

LoadTimeBasedAggregateHandlerFunctionFactory

class LoadTimeBasedAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED) : AggregateRouteHandlerFunctionFactorySupport

LoadVersionedAggregateHandlerFunction

class LoadVersionedAggregateHandlerFunction(aggregateRouteMetadata: AggregateRouteMetadata<*>, stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED) : AbstractLoadAggregateHandlerFunction

LoadVersionedAggregateHandlerFunctionFactory

class LoadVersionedAggregateHandlerFunctionFactory(stateAggregateRepository: StateAggregateRepository, exceptionHandler: RequestExceptionHandler, admission: PointReadAdmission = PointReadAdmission.DISABLED) : AggregateRouteHandlerFunctionFactorySupport

PointReadAdmission

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.