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

Package-level declarations

Types

abstract class AbstractSnapshotQueryBackendFactory : SnapshotQueryBackendFactory

class DefaultSnapshotQueryGateway<S : Any>(namedAggregate: NamedAggregate, binding: QueryBackendBinding<SnapshotQueryBackend>, targetType: JavaType, filters: List<QueryFilter> = emptyList(), policies: List<QueryPolicy> = emptyList(), observer: QueryObserver = QueryLogObserver()) : SnapshotQueryGateway<S> , AbstractQueryGateway<MaterializedSnapshot<S>>

NoOpSnapshotQueryBackend

class NoOpSnapshotQueryBackend(val namedAggregate: NamedAggregate) : SnapshotQueryBackend

NoOpSnapshotQueryBackendFactory

object NoOpSnapshotQueryBackendFactory : AbstractSnapshotQueryBackendFactory

RoutingSnapshotQueryBackendFactory

class RoutingSnapshotQueryBackendFactory(defaultFactory: SnapshotQueryBackendFactory, routes: Map<NamedAggregate, SnapshotQueryBackendFactory>) : SnapshotQueryBackendFactory

SnapshotQueryBackend

interface SnapshotQueryBackend : QueryBackend, Named

SnapshotQueryBackendFactory

interface SnapshotQueryBackendFactory

SnapshotQueryGateway

interface SnapshotQueryGateway<S : Any> : QueryGateway<MaterializedSnapshot<S>>

Functions

count

fun Condition.~~count~~(queryGateway: SnapshotQueryGateway<*>): Mono<Long>

fun FilterExpression.count(queryGateway: SnapshotQueryGateway<*>): Mono<Long>

dynamicQuery

fun ICursorQuery.dynamicQuery(queryGateway: SnapshotQueryGateway<*>): Mono<CursorPage<ObjectNode>>

fun IListQuery.dynamicQuery(queryGateway: SnapshotQueryGateway<*>): Flux<ObjectNode>

fun IPagedQuery.dynamicQuery(queryGateway: SnapshotQueryGateway<*>): Mono<PagedList<ObjectNode>>

fun ISingleQuery.dynamicQuery(queryGateway: SnapshotQueryGateway<*>): Mono<ObjectNode>

nestedState

fun NestedFieldDsl.nestedState()

pathState

fun FilterDsl.pathState(block: FilterDsl.() -> Unit)

Applies block in the snapshot state path scope.

query

fun AggregationQuery.query(queryGateway: SnapshotQueryGateway<*>): Flux<ObjectNode>

fun <S : Any> ICursorQuery.query(queryGateway: SnapshotQueryGateway<S>): Mono<CursorPage<MaterializedSnapshot<S>>>

fun <S : Any> IListQuery.query(queryGateway: SnapshotQueryGateway<S>): Flux<MaterializedSnapshot<S>>

fun <S : Any> IPagedQuery.query(queryGateway: SnapshotQueryGateway<S>): Mono<PagedList<MaterializedSnapshot<S>>>

fun <S : Any> ISingleQuery.query(queryGateway: SnapshotQueryGateway<S>): Mono<MaterializedSnapshot<S>>

toState

fun <S : Any> Flux<MaterializedSnapshot<S>>.toState(): Flux<S>

fun <S : Any> Mono<MaterializedSnapshot<S>>.toState(): Mono<S>

fun ObjectNode.toState(): ObjectNode

toStateCursorPage

fun <S : Any> Mono<CursorPage<MaterializedSnapshot<S>>>.toStateCursorPage(): Mono<CursorPage<S>>

toStateDocument

fun Flux<out ObjectNode>.toStateDocument(): Flux<ObjectNode>

fun Mono<out ObjectNode>.toStateDocument(): Mono<ObjectNode>

toStateDocumentCursorPage

fun Mono<CursorPage<ObjectNode>>.toStateDocumentCursorPage(): Mono<CursorPage<ObjectNode>>

toStateDocumentPagedList

fun <S : ObjectNode> Mono<PagedList<S>>.toStateDocumentPagedList(): Mono<PagedList<ObjectNode>>

toStatePagedList

fun <S : Any> Mono<PagedList<MaterializedSnapshot<S>>>.toStatePagedList(): Mono<PagedList<S>>