wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.webflux/WebFluxAutoConfiguration

WebFluxAutoConfiguration

@AutoConfiguration(after = [CommandAutoConfiguration::class, OpenAPIAutoConfiguration::class])

@EnableConfigurationProperties(value = [WebFluxProperties::class])

@ConditionalOnClass(name = ["org.springframework.web.server.WebFilter", "me.ahoo.wow.webflux.route.command.CommandHandlerFunction"])

class WebFluxAutoConfiguration

WebFlux Auto Configuration .

Author

ahoo wang

Constructors

WebFluxAutoConfiguration

constructor()

Functions

batchExecutionPolicy

@Bean

@ConditionalOnMissingBean

fun batchExecutionPolicy(webFluxProperties: WebFluxProperties): BatchExecutionPolicy

commandBuilderExtractor

@Bean

@ConditionalOnMissingBean

fun commandBuilderExtractor(): CommandBuilderExtractor

commandMessageExtractor

@Bean

@ConditionalOnMissingBean

fun commandMessageExtractor(commandMessageFactory: CommandMessageFactory, commandBuilderExtractor: CommandBuilderExtractor, commandRequestHeaderAppenderObjectProvider: ObjectProvider<CommandRequestHeaderAppender>, identityHeaderAliases: ObjectProvider<IdentityHeaderAliases>): CommandMessageExtractor

commandRequestExtendHeaderAppender

@Bean

fun commandRequestExtendHeaderAppender(): CommandRequestExtendHeaderAppender

commandRequestRemoteIpHeaderAppender

@Bean

@ConditionalOnProperty(value = ["wow.webflux.command.request.appender.ip.enabled"], matchIfMissing = true, havingValue = "true")

fun commandRequestRemoteIpHeaderAppender(): CommandRequestRemoteIpHeaderAppender

commandRequestUserAgentHeaderAppender

@Bean

@ConditionalOnProperty(value = ["wow.webflux.command.request.appender.agent.enabled"], matchIfMissing = true, havingValue = "true")

fun commandRequestUserAgentHeaderAppender(): CommandRequestUserAgentHeaderAppender

commandRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun commandRouteModule(waitCoordinator: WaitCoordinator, commandGateway: CommandGateway, commandMessageExtractor: CommandMessageExtractor, exceptionHandler: RequestExceptionHandler, commandWaitPolicy: CommandWaitPolicy): CommandRouteModule

commandRouterFunction

@Bean

fun commandRouterFunction(routerSpecs: RouterSpecs, routeHandlerFunctionRegistrar: RouteHandlerFunctionRegistrar, identityHeaderAliases: ObjectProvider<IdentityHeaderAliases>): RouterFunction<ServerResponse>

commandWaitPolicy

@Bean

@ConditionalOnMissingBean

fun commandWaitPolicy(): CommandWaitPolicy

eventRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun eventRouteModule(eventStore: EventStore, stateEventCompensator: StateEventCompensator, eventCompensateSupporter: EventCompensateSupporter?, exceptionHandler: RequestExceptionHandler, batchExecutionPolicy: BatchExecutionPolicy): EventRouteModule

exceptionHandler

@Bean

@ConditionalOnMissingBean

fun exceptionHandler(errorStrategy: WebFluxErrorStrategy): RequestExceptionHandler

globalExceptionHandler

@Bean

fun globalExceptionHandler(errorStrategy: WebFluxErrorStrategy): WebExceptionHandler

@Bean

@ConditionalOnMissingBean

fun httpQueryGuard(webFluxProperties: WebFluxProperties): HttpQueryGuard

pointReadAdmission

@Bean

@ConditionalOnMissingBean

fun pointReadAdmission(webFluxProperties: WebFluxProperties, queryRequestScope: QueryRequestScope, queryPolicies: ObjectProvider<QueryPolicy>, snapshotQueryBackendFactory: ObjectProvider<SnapshotQueryBackendFactory>, eventStreamQueryBackendFactory: ObjectProvider<EventStreamQueryBackendFactory>, querySchemaCatalog: ObjectProvider<QuerySchemaCatalog>, queryEntryPolicy: ObjectProvider<QueryEntryPolicy>, scopeContributors: ObjectProvider<ScopeContributor>): PointReadAdmission

Point-read admission, when wow.webflux.state.point-read-admission is on, under the same caller scope as the query routes: the QueryRequestScope and every ScopeContributor.

queryRequestScope

@Bean

@ConditionalOnMissingBean

fun queryRequestScope(identityHeaderAliases: ObjectProvider<IdentityHeaderAliases>): QueryRequestScope

DefaultQueryRequestScope, applying the identity header aliases also to a query handler invoked outside the router (the router hands its own routes their aliases).

queryRouteModule

@Bean(value = ["queryRouteModule"])

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun queryRouteModule(beanFactory: BeanFactory, queryRequestScope: QueryRequestScope, scopeContributors: ObjectProvider<ScopeContributor>, exceptionHandler: RequestExceptionHandler, httpQueryGuard: HttpQueryGuard): QueryRouteModule

routeHandlerFunctionRegistrar

@Bean

fun routeHandlerFunctionRegistrar(routeModules: ObjectProvider<WebFluxRouteModule>, httpFactories: ObjectProvider<HttpRouteHandlerFunctionFactory>): RouteHandlerFunctionRegistrar

snapshotRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun snapshotRouteModule(stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, snapshotStore: SnapshotStore, exceptionHandler: RequestExceptionHandler, batchExecutionPolicy: BatchExecutionPolicy): SnapshotRouteModule

stateRouteModule

@Bean

@Order(value = -2147483648)

@ConditionalOnMissingBean

fun stateRouteModule(stateAggregateRepository: StateAggregateRepository, stateAggregateFactory: StateAggregateFactory, eventStore: EventStore, exceptionHandler: RequestExceptionHandler, tracingPolicy: TracingPolicy, pointReadAdmission: PointReadAdmission): StateRouteModule

@Bean

@ConditionalOnMissingBean

fun tracingPolicy(): TracingPolicy

webFluxErrorStrategy

@Bean

@ConditionalOnMissingBean

fun webFluxErrorStrategy(): WebFluxErrorStrategy