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)

EventStreamQueryServiceFactoryBinding

data class EventStreamQueryServiceFactoryBinding(val name: String, val storage: StorageType?, val eventStreamQueryServiceFactory: EventStreamQueryServiceFactory)

OnStorageRoutingStorageCondition

class OnStorageRoutingStorageCondition : SpringBootCondition

ResolvedEventRoutes

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

ResolvedEventStreamQueryServiceFactoryRoutes

data class ResolvedEventStreamQueryServiceFactoryRoutes(val defaultEventStreamQueryServiceFactory: EventStreamQueryServiceFactory, val eventStreamQueryServiceFactoryRoutes: Map<NamedAggregate, EventStreamQueryServiceFactory>)

ResolvedSnapshotQueryServiceFactoryRoutes

data class ResolvedSnapshotQueryServiceFactoryRoutes(val defaultSnapshotQueryServiceFactory: SnapshotQueryServiceFactory, val snapshotQueryServiceFactoryRoutes: Map<NamedAggregate, SnapshotQueryServiceFactory>)

ResolvedSnapshotRoutes

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

SnapshotQueryServiceFactoryBinding

data class SnapshotQueryServiceFactoryBinding(val name: String, val storage: StorageType?, val snapshotQueryServiceFactory: SnapshotQueryServiceFactory)

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>, eventStreamQueryServiceFactoryBindings: List<EventStreamQueryServiceFactoryBinding> = emptyList(), snapshotQueryServiceFactoryBindings: List<SnapshotQueryServiceFactoryBinding> = 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())