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

Package-level declarations

Types

AggregateStorageRouteProperties

data class AggregateStorageRouteProperties(val event: StorageChannelRouteProperties? = null, val 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)

EventStreamQueryBackendFactoryBinding

data class EventStreamQueryBackendFactoryBinding(val name: String, val storage: StorageType?, val eventStreamQueryBackendFactory: EventStreamQueryBackendFactory)

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>)

SnapshotQueryBackendFactoryBinding

data class SnapshotQueryBackendFactoryBinding(val name: String, val storage: StorageType?, val snapshotQueryBackendFactory: SnapshotQueryBackendFactory)

SnapshotStoreBinding

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

StorageChannelRouteProperties

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

StorageRouteResolver

class StorageRouteResolver(contextName: String, snapshotEnabled: Boolean, eventStoreBindings: List<EventStoreBinding>, snapshotStoreBindings: List<SnapshotStoreBinding>, eventStreamQueryBackendFactoryBindings: List<EventStreamQueryBackendFactoryBinding> = emptyList(), snapshotQueryBackendFactoryBindings: List<SnapshotQueryBackendFactoryBinding> = emptyList(), defaultEventStorage: StorageType = StorageType.MONGO, defaultSnapshotStorage: StorageType = StorageType.MONGO)

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(val aggregates: Map<String, AggregateStorageRouteProperties> = emptyMap())