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

Package-level declarations

Types

AbstractSnapshotQueryServiceFactory

abstract class AbstractSnapshotQueryServiceFactory : SnapshotQueryServiceFactory

NoOpSnapshotQueryService

class NoOpSnapshotQueryService<S : Any>(val namedAggregate: NamedAggregate) : SnapshotQueryService<S>

NoOpSnapshotQueryServiceFactory

object NoOpSnapshotQueryServiceFactory : SnapshotQueryServiceFactory

SnapshotQueryService

interface SnapshotQueryService<S : Any> : NamedAggregateDecorator

SnapshotQueryServiceFactory

interface SnapshotQueryServiceFactory

Functions

fun Condition.count(queryService: SnapshotQueryService<*>): Mono<Long>

fun IListQuery.dynamicQuery(queryService: SnapshotQueryService<*>): Flux<DynamicDocument>

fun IPagedQuery.dynamicQuery(queryService: SnapshotQueryService<*>): Mono<PagedList<DynamicDocument>>

fun ISingleQuery.dynamicQuery(queryService: SnapshotQueryService<*>): Mono<DynamicDocument>

fun NestedFieldDsl.nestedState()

fun <S : Any> IListQuery.query(queryService: SnapshotQueryService<S>): Flux<MaterializedSnapshot<S>>

fun <S : Any> IPagedQuery.query(queryService: SnapshotQueryService<S>): Mono<PagedList<MaterializedSnapshot<S>>>

fun <S : Any> ISingleQuery.query(queryService: SnapshotQueryService<S>): Mono<MaterializedSnapshot<S>>

fun DynamicDocument.toState(): DynamicDocument

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

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

toStateDocument

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

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

toStateDocumentPagedList

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

toStatePagedList

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