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

DefaultSnapshotQueryHandler

class DefaultSnapshotQueryHandler(chain: FilterChain<SnapshotQueryContext<*, *, *>>, errorHandler: ErrorHandler<SnapshotQueryContext<*, *, *>> = LogErrorHandler()) : AbstractHandler<SnapshotQueryContext<*, *, *>> , SnapshotQueryHandler

Constructors

Link copied to clipboard
constructor(chain: FilterChain<SnapshotQueryContext<*, *, *>>, errorHandler: ErrorHandler<SnapshotQueryContext<*, *, *>> = LogErrorHandler())

Functions

Link copied to clipboard
open fun count(namedAggregate: NamedAggregate, condition: Condition): Mono<Long>
Link copied to clipboard
open fun dynamicList(namedAggregate: NamedAggregate, query: IListQuery): Flux<DynamicDocument>
Link copied to clipboard
open fun dynamicPaged(namedAggregate: NamedAggregate, pagedQuery: IPagedQuery): Mono<PagedList<DynamicDocument>>
Link copied to clipboard
open fun dynamicSingle(namedAggregate: NamedAggregate, singleQuery: ISingleQuery): Mono<DynamicDocument>
Link copied to clipboard
abstract fun handle(context: SnapshotQueryContext<*, *, *>): Mono<Void>
Link copied to clipboard
open fun <S : Any> list(namedAggregate: NamedAggregate, query: IListQuery): Flux<MaterializedSnapshot<S>>
Link copied to clipboard
open fun <S : Any> paged(namedAggregate: NamedAggregate, pagedQuery: IPagedQuery): Mono<PagedList<MaterializedSnapshot<S>>>
Link copied to clipboard
open fun <S : Any> single(namedAggregate: NamedAggregate, singleQuery: ISingleQuery): Mono<MaterializedSnapshot<S>>