wow-mongo/me.ahoo.wow.mongo

Package-level declarations

Types

AggregateSchemaInitializer

object AggregateSchemaInitializer

Documents

object Documents

EventStreamSchemaInitializer

class EventStreamSchemaInitializer(database: MongoDatabase, enableRequestIdUniqueIndex: Boolean = false)

MongoDatabaseContextGuard

class MongoDatabaseContextGuard(database: MongoDatabase)

Enforces the default deployment invariant that one MongoDB database belongs to one bounded context.

MongoEventStore

class MongoEventStore(database: MongoDatabase, val batchOptions: MongoEventStoreBatchOptions = MongoEventStoreBatchOptions(), metrics: WowMetrics = WowMetrics.NONE) : AbstractEventStore, Closeable

MongoEventStoreBatchCloseTimeoutException

class MongoEventStoreBatchCloseTimeoutException(val timeout: Duration) : IllegalStateException

MongoEventStoreBatchOptions

data class MongoEventStoreBatchOptions(val enabled: Boolean = false, val maxSize: Int = DEFAULT_MAX_SIZE, val maxDelay: Duration = DEFAULT_MAX_DELAY, val maxPendingAppends: Int = DEFAULT_MAX_PENDING_APPENDS, val laneCount: Int = DEFAULT_LANE_COUNT)

Controls transparent batching for MongoEventStore appends.

MongoEventStoreBatchOverflowException

class MongoEventStoreBatchOverflowException(val maxPendingAppends: Int) : IllegalStateException, RecoverableException

MongoJacksonModule

class MongoJacksonModule : SimpleModule

MongoRecoverableExceptionProvider

class MongoRecoverableExceptionProvider : RecoverableExceptionProvider

Registers MongoDB transient/recoverable error codes as RecoverableType.RECOVERABLE, enabling the framework's retry mechanism to automatically handle these errors.

MongoSnapshotStore

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

MongoSnapshotStoreBatchCloseTimeoutException

class MongoSnapshotStoreBatchCloseTimeoutException(val timeout: Duration) : IllegalStateException

MongoSnapshotStoreBatchOptions

data class MongoSnapshotStoreBatchOptions(val enabled: Boolean = false, val maxSize: Int = DEFAULT_MAX_SIZE, val maxDelay: Duration = DEFAULT_MAX_DELAY, val maxPendingSaves: Int = DEFAULT_MAX_PENDING_SAVES, val laneCount: Int = DEFAULT_LANE_COUNT)

Controls transparent batching for MongoSnapshotStore saves.

MongoSnapshotStoreBatchOverflowException

class MongoSnapshotStoreBatchOverflowException(val maxPendingSaves: Int) : IllegalStateException, RecoverableException

RecoverableMongoBulkWriteException

class RecoverableMongoBulkWriteException(val error: WriteError, bulkWriteException: MongoBulkWriteException) : MongoException, RecoverableException

RecoverableMongoWriteException

class RecoverableMongoWriteException(writeException: MongoWriteException) : MongoException, RecoverableException

SnapshotSchemaInitializer

class SnapshotSchemaInitializer(database: MongoDatabase)

Functions

isRecoverableWriteError

fun WriteError.isRecoverableWriteError(): Boolean

toDocument

fun DomainEventStream.toDocument(): Document

fun <S : Any> Snapshot<S>.toDocument(): Document

toDomainEventStream

fun Document.toDomainEventStream(): DomainEventStream

toMaterializedSnapshot

fun <S : Any> Document.toMaterializedSnapshot(snapshotType: JavaType): MaterializedSnapshot<S>

fun <S : Any> Flux<Document>.toMaterializedSnapshot(snapshotType: JavaType): Flux<MaterializedSnapshot<S>>

fun <S : Any> Mono<Document>.toMaterializedSnapshot(snapshotType: JavaType): Mono<MaterializedSnapshot<S>>

toObjectNode

fun Document.toObjectNode(): ObjectNode

toSnapshot

fun <S : Any> Document.toSnapshot(): Snapshot<S>

fun <S : Any> Flux<Document>.toSnapshot(): Flux<Snapshot<S>>

fun <S : Any> Mono<Document>.toSnapshot(): Mono<Snapshot<S>>

toSnapshotState

fun <S : Any> Document.toSnapshotState(): S

fun <S : Any> Flux<Document>.toSnapshotState(): Flux<S>

fun <S : Any> Mono<Document>.toSnapshotState(): Mono<S>

toWowError

fun MongoWriteException.toWowError(eventStream: DomainEventStream): Throwable