wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.eventsourcing.routing

Package-level declarations

Types

AggregateStorageRouteProperties

data class AggregateStorageRouteProperties(var event: StorageChannelRouteProperties? = null, var snapshot: StorageChannelRouteProperties? = null)

ConditionalOnEventStoreStorage

@Target(allowedTargets = [AnnotationTarget.CLASS, AnnotationTarget.FUNCTION])

@Conditional(value = [OnStorageRoutingStorageCondition::class])

annotation class ConditionalOnEventStoreStorage(val value: StorageType)

ConditionalOnSnapshotStoreStorage

@Target(allowedTargets = [AnnotationTarget.CLASS, AnnotationTarget.FUNCTION])

@Conditional(value = [OnStorageRoutingStorageCondition::class])

annotation class ConditionalOnSnapshotStoreStorage(val value: StorageType)

EventStoreBinding

data class EventStoreBinding(val name: String, val storage: StorageType?, val eventStore: EventStore)

OnStorageRoutingStorageCondition

class OnStorageRoutingStorageCondition : SpringBootCondition

ResolvedEventRoutes

data class ResolvedEventRoutes(val defaultEventStore: EventStore, val eventRoutes: Map<NamedAggregate, EventStore>)

ResolvedEventStreamQueryBackendFactoryRoutes

data class ResolvedEventStreamQueryBackendFactoryRoutes(val defaultEventStreamQueryBackendFactory: EventStreamQueryBackendFactory, val eventStreamQueryBackendFactoryRoutes: Map<NamedAggregate, EventStreamQueryBackendFactory>)

ResolvedSnapshotQueryBackendFactoryRoutes

data class ResolvedSnapshotQueryBackendFactoryRoutes(val defaultSnapshotQueryBackendFactory: SnapshotQueryBackendFactory, val snapshotQueryBackendFactoryRoutes: Map<NamedAggregate, SnapshotQueryBackendFactory>)

ResolvedSnapshotRoutes

data class ResolvedSnapshotRoutes(val defaultSnapshotStore: SnapshotStore, val snapshotRoutes: Map<NamedAggregate, SnapshotStore>)

SnapshotStoreBinding

data class SnapshotStoreBinding(val name: String, val storage: StorageType?, val snapshotStore: SnapshotStore)

StorageChannelRouteProperties

data class StorageChannelRouteProperties(var storage: StorageType? = null, var binding: String? = null)

StorageRouteResolver

class StorageRouteResolver(contextName: String, snapshotEnabled: Boolean, eventStoreBindings: List<EventStoreBinding>, snapshotStoreBindings: List<SnapshotStoreBinding>, queryBackendProviders: List<QueryBackendProvider> = emptyList(), defaultEventStorage: StorageType = StorageType.MONGO, defaultSnapshotStorage: StorageType = StorageType.MONGO, defaultEventBinding: String? = null, defaultSnapshotBinding: String? = null)

StorageRoutingAutoConfiguration

@AutoConfiguration(after = [EventSourcingAutoConfiguration::class, EventStoreAutoConfiguration::class, SnapshotAutoConfiguration::class, MongoEventSourcingAutoConfiguration::class, RedisEventSourcingAutoConfiguration::class, ElasticsearchEventSourcingAutoConfiguration::class, MockEventStoreAutoConfiguration::class, MockSnapshotAutoConfiguration::class, QueryAutoConfiguration::class])

@EnableConfigurationProperties(value = [StorageRoutingProperties::class, EventStoreProperties::class, SnapshotProperties::class])

class StorageRoutingAutoConfiguration

StorageRoutingProperties

@ConfigurationProperties(prefix = "wow.eventsourcing.storage-routing")

data class StorageRoutingProperties(var aggregates: Map<String, AggregateStorageRouteProperties> = emptyMap())

Properties

queryBackendProviderName

val StorageType.queryBackendProviderName: String

The name a built-in storage registers its me.ahoo.wow.query.QueryBackendProviders under, for example mongo.