wow-query/me.ahoo.wow.query.snapshot.filter/DefaultSnapshotQueryHandler

DefaultSnapshotQueryHandler

class DefaultSnapshotQueryHandler(chain: FilterChain<QueryContext<*, *>>, errorHandler: ErrorHandler<QueryContext<*, *>> = LogErrorHandler()) : SnapshotQueryHandler, AbstractQueryHandler<MaterializedSnapshot<Any>>

Constructors

DefaultSnapshotQueryHandler

constructor(chain: FilterChain<QueryContext<*, *>>, errorHandler: ErrorHandler<QueryContext<*, *>> = LogErrorHandler())

Functions

open fun count(namedAggregate: NamedAggregate, condition: Condition): Mono<Long>

open fun dynamicList(namedAggregate: NamedAggregate, listQuery: IListQuery): Flux<DynamicDocument>

open fun dynamicPaged(namedAggregate: NamedAggregate, pagedQuery: IPagedQuery): Mono<PagedList<DynamicDocument>>

open fun dynamicSingle(namedAggregate: NamedAggregate, singleQuery: ISingleQuery): Mono<DynamicDocument>

open fun handle(context: QueryContext<*, *>): Mono<Void>

open fun list(namedAggregate: NamedAggregate, listQuery: IListQuery): Flux<MaterializedSnapshot<Any>>

open fun paged(namedAggregate: NamedAggregate, pagedQuery: IPagedQuery): Mono<PagedList<MaterializedSnapshot<Any>>>

open fun single(namedAggregate: NamedAggregate, singleQuery: ISingleQuery): Mono<MaterializedSnapshot<Any>>