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

Package-level declarations

Types

abstract class AbstractQueryRequestScope : QueryRequestScope

class CountQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryGateway: QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard()) : HandlerFunction<ServerResponse>

CountQueryHandlerFunctionFactory

open class CountQueryHandlerFunctionFactory(handlerKey: String, queryGateway: (AggregateMetadata<*, *>) -> QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard()) : AggregateRouteHandlerFunctionFactorySupport

CursorQueryHandlerFunction

class CursorQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryGateway: QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Mono<CursorPage<ObjectNode>>) -> Mono<CursorPage<ObjectNode>> = { it }) : HandlerFunction<ServerResponse>

CursorQueryHandlerFunctionFactory

open class CursorQueryHandlerFunctionFactory(handlerKey: String, queryGateway: (AggregateMetadata<*, *>) -> QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Mono<CursorPage<ObjectNode>>) -> Mono<CursorPage<ObjectNode>> = { it }) : AggregateRouteHandlerFunctionFactorySupport

DefaultQueryRequestScope

object DefaultQueryRequestScope : AbstractQueryRequestScope

HttpQueryGuard

class HttpQueryGuard(maxListSize: Int = 1000, maxPageSize: Int = 100, maxPageWindow: Long, maxFilterNodes: Int = DEFAULT_MAX_FILTER_NODES, maxFilterValues: Int = 1000, allowExpensiveOperators: Boolean = true, idleTimeout: Duration = Duration.ofSeconds(10))

ListQueryHandlerFunction

class ListQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryGateway: QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Flux<ObjectNode>) -> Flux<ObjectNode>) : HandlerFunction<ServerResponse>

ListQueryHandlerFunctionFactory

open class ListQueryHandlerFunctionFactory(handlerKey: String, queryGateway: (AggregateMetadata<*, *>) -> QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Flux<ObjectNode>) -> Flux<ObjectNode> = { it }) : AggregateRouteHandlerFunctionFactorySupport

PagedQueryHandlerFunction

class PagedQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryGateway: QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Mono<PagedList<ObjectNode>>) -> Mono<PagedList<ObjectNode>>) : HandlerFunction<ServerResponse>

PagedQueryHandlerFunctionFactory

open class PagedQueryHandlerFunctionFactory(handlerKey: String, queryGateway: (AggregateMetadata<*, *>) -> QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Mono<PagedList<ObjectNode>>) -> Mono<PagedList<ObjectNode>> = { it }) : AggregateRouteHandlerFunctionFactorySupport

QueryBodyExtractor

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

QueryRequestScope

fun interface QueryRequestScope

SingleQueryHandlerFunction

class SingleQueryHandlerFunction(aggregateMetadata: AggregateMetadata<*, *>, queryGateway: QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Mono<ObjectNode>) -> Mono<ObjectNode>) : HandlerFunction<ServerResponse>

SingleQueryHandlerFunctionFactory

open class SingleQueryHandlerFunctionFactory(handlerKey: String, queryGateway: (AggregateMetadata<*, *>) -> QueryGateway<*>, queryRequestScope: QueryRequestScope, exceptionHandler: RequestExceptionHandler, guard: HttpQueryGuard = HttpQueryGuard(), rewriteResult: (Mono<ObjectNode>) -> Mono<ObjectNode> = { it }) : AggregateRouteHandlerFunctionFactorySupport