MongoEventSourcingAutoConfiguration

@AutoConfiguration(after = [WowAutoConfiguration::class, MongoReactiveAutoConfiguration::class, QuerySchemaAutoConfiguration::class])
@ConditionalOnClass(value = [MongoEventStore::class])
class MongoEventSourcingAutoConfiguration(mongoProperties: MongoProperties, eventStoreBatchProperties: MongoEventStoreBatchProperties, snapshotStoreBatchProperties: MongoSnapshotStoreBatchProperties)

Constructors

Link copied to clipboard
constructor(mongoProperties: MongoProperties, eventStoreBatchProperties: MongoEventStoreBatchProperties, snapshotStoreBatchProperties: MongoSnapshotStoreBatchProperties)

Functions

Link copied to clipboard
fun mongoEventStore(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext, metrics: ObjectProvider<WowMetrics>): MongoEventStore
Link copied to clipboard
fun mongoEventStoreBinding(@Qualifier(value = "mongoEventStore") eventStore: EventStore): EventStoreBinding
Link copied to clipboard
fun mongoEventStreamQueryBackendFactory(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext, sources: List<QuerySchemaSource> = emptyList()): MongoEventStreamQueryBackendFactory
Link copied to clipboard
@Bean
@ConditionalOnBean(value = [MongoClient::class])
@ConditionalOnProperty(value = ["wow.prepare.storage"], matchIfMissing = true, havingValue = "mongo")
@ConditionalOnMissingBean
fun mongoPrepareKeyFactory(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext): PrepareKeyFactory
Link copied to clipboard
fun mongoSnapshotQueryBackendFactory(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext, sources: List<QuerySchemaSource>): MongoSnapshotQueryBackendFactory
Link copied to clipboard
fun mongoSnapshotStore(mongoClient: MongoClient, dataMongoProperties: MongoProperties?, @Qualifier(value = "wow.CurrentBoundedContext") currentBoundedContext: NamedBoundedContext, metrics: ObjectProvider<WowMetrics>): MongoSnapshotStore
Link copied to clipboard
fun mongoSnapshotStoreBinding(@Qualifier(value = "mongoSnapshotStore") snapshotStore: SnapshotStore): SnapshotStoreBinding