wow-mongo/me.ahoo.wow.mongo.query.event/MongoEventStreamQueryService

MongoEventStreamQueryService

class MongoEventStreamQueryService(val namedAggregate: NamedAggregate, val collection: MongoCollection<Document>, val converter: ConditionConverter<Bson> = EventStreamConditionConverter) : AbstractMongoQueryService<DomainEventStream> , EventStreamQueryService

Constructors

constructor(namedAggregate: NamedAggregate, collection: MongoCollection<Document>, converter: ConditionConverter<Bson> = EventStreamConditionConverter)

Properties

aggregateName

open override val aggregateName: String

collection

open override val collection: MongoCollection<Document>

contextName

open override val contextName: String

converter

open override val converter: ConditionConverter<Bson>

namedAggregate

open override val namedAggregate: NamedAggregate

Functions

count

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

dynamicList

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

dynamicPaged

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

dynamicSingle

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

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

list

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

paged

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

single

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

toDynamicDocument

open override fun toDynamicDocument(document: Document): DynamicDocument

toEventStreamCollectionName

fun NamedAggregate.toEventStreamCollectionName(): String

toSnapshotCollectionName

fun NamedAggregate.toSnapshotCollectionName(): String

toTypedResult

open override fun toTypedResult(document: Document): DomainEventStream