MongoSnapshotStore

class MongoSnapshotStore(database: MongoDatabase, val batchOptions: BatchOptions? = null, metrics: WowMetrics = WowMetrics.NONE) : SnapshotStore

Constructors

constructor(database: MongoDatabase, batchOptions: BatchOptions? = null, metrics: WowMetrics = WowMetrics.NONE)

open override val name: String

The batch writer of this store's snapshots, flushed by the runtime after its dispatchers stop (me.ahoo.wow.runtime.RuntimeResources); RuntimeResource.NONE when the store writes directly.

open override fun close()

open override fun getVersion(aggregateId: AggregateId): Mono<Int>

open override fun <S : Any> load(aggregateId: AggregateId): Mono<Snapshot<S>>

open override fun <S : Any> save(snapshot: Snapshot<S>): Mono<Void>