5.3.8

wow-mongo/me.ahoo.wow.mongo.query/AbstractMongoQueryService

AbstractMongoQueryService

abstract class AbstractMongoQueryService<R : Any> : QueryService<R>

Inheritors

MongoEventStreamQueryService

MongoSnapshotQueryService

Constructors

AbstractMongoQueryService

constructor()

Properties

open override val aggregateName: String

abstract val collection: MongoCollection<Document>

open override val contextName: String

abstract val converter: ConditionConverter<Bson>

abstract val namedAggregate: NamedAggregate

Functions

open override fun count(condition: Condition): Mono<Long>

open override fun dynamicList(listQuery: IListQuery): Flux<DynamicDocument>

open override fun dynamicPaged(pagedQuery: IPagedQuery): Mono<PagedList<DynamicDocument>>

open override fun dynamicSingle(singleQuery: ISingleQuery): Mono<DynamicDocument>

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open override fun list(listQuery: IListQuery): Flux<R>

open override fun paged(pagedQuery: IPagedQuery): Mono<PagedList<R>>

open override fun single(singleQuery: ISingleQuery): Mono<R>

toDynamicDocument

abstract fun toDynamicDocument(document: Document): DynamicDocument

toEventStreamCollectionName

fun NamedAggregate.toEventStreamCollectionName(): String

toSnapshotCollectionName

fun NamedAggregate.toSnapshotCollectionName(): String

abstract fun toTypedResult(document: Document): R