wow-query/me.ahoo.wow.query/QueryGateway

QueryGateway

interface QueryGateway<R : Any> : NamedAggregateDecorator

Inheritors

AbstractQueryGateway

DatasetQueryGateway

EventStreamQueryGateway

SnapshotQueryGateway

Properties

entryPolicy

open val entryPolicy: QueryEntryPolicy

The entry policy this gateway admits every query under: the one source of each entry's budget. The default, for a gateway compiled against 9.1 that does not declare one, is QueryEntryPolicy.DEFAULT.

Functions

aggregate

abstract fun aggregate(query: AggregationQuery): Flux<ObjectNode>

count

abstract fun count(filter: FilterExpression): Mono<Long>

cursor

abstract fun cursor(query: ICursorQuery): Mono<CursorPage<R>>

describe

open fun describe(entry: QueryEntry, defaultListSize: Int? = null): Mono<QueryModelDescriptor>

How this model can be queried on entry (design §7): the capability descriptor of the schema this gateway admits against, under the budget entryPolicy gives entry. defaultListSize is the list size the entry's adapter applies when a list query sends none, or null.

dynamicCursor

abstract fun dynamicCursor(query: ICursorQuery): Mono<CursorPage<ObjectNode>>

dynamicList

abstract fun dynamicList(query: IListQuery): Flux<ObjectNode>

dynamicPaged

abstract fun dynamicPaged(query: IPagedQuery): Mono<PagedList<ObjectNode>>

dynamicSingle

abstract fun dynamicSingle(query: ISingleQuery): Mono<ObjectNode>

list

abstract fun list(query: IListQuery): Flux<R>

paged

abstract fun paged(query: IPagedQuery): Mono<PagedList<R>>

single

abstract fun single(query: ISingleQuery): Mono<R>