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

Package-level declarations

Types

AbstractRewriteRequestCondition

abstract class AbstractRewriteRequestCondition : RewriteRequestCondition

CountQueryHandlerFunction

class CountQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler) : HandlerFunction<ServerResponse>

CountQueryHandlerFunctionFactory

open class CountQueryHandlerFunctionFactory(handlerKey: String, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler) : AggregateRouteHandlerFunctionFactorySupport

DefaultRewriteRequestCondition

object DefaultRewriteRequestCondition : AbstractRewriteRequestCondition

ListQueryHandlerFunction

class ListQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler, rewriteResult: (Flux<DynamicDocument>) -> Flux<DynamicDocument>) : HandlerFunction<ServerResponse>

ListQueryHandlerFunctionFactory

open class ListQueryHandlerFunctionFactory(handlerKey: String, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler, rewriteResult: (Flux<DynamicDocument>) -> Flux<DynamicDocument> = { it }) : AggregateRouteHandlerFunctionFactorySupport

PagedQueryHandlerFunction

class PagedQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler, rewriteResult: (Mono<PagedList<DynamicDocument>>) -> Mono<PagedList<DynamicDocument>>) : HandlerFunction<ServerResponse>

PagedQueryHandlerFunctionFactory

open class PagedQueryHandlerFunctionFactory(handlerKey: String, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler, rewriteResult: (Mono<PagedList<DynamicDocument>>) -> Mono<PagedList<DynamicDocument>> = { it }) : AggregateRouteHandlerFunctionFactorySupport

QueryBodyExtractor

class QueryBodyExtractor<Q : Any>(queryType: Class<Q>) : BodyExtractor<Mono<Q>, ReactiveHttpInputMessage>

RewriteRequestCondition

interface RewriteRequestCondition

SingleQueryHandlerFunction

class SingleQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler, rewriteResult: (Mono<DynamicDocument>) -> Mono<DynamicDocument>) : HandlerFunction<ServerResponse>

SingleQueryHandlerFunctionFactory

open class SingleQueryHandlerFunctionFactory(handlerKey: String, queryHandler: QueryHandler<*>, rewriteRequestCondition: RewriteRequestCondition, exceptionHandler: RequestExceptionHandler, rewriteResult: (Mono<DynamicDocument>) -> Mono<DynamicDocument> = { it }) : AggregateRouteHandlerFunctionFactorySupport