wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.elasticsearch/ElasticsearchEventSourcingAutoConfiguration

ElasticsearchEventSourcingAutoConfiguration

@AutoConfiguration(after = [ElasticsearchRestClientAutoConfiguration::class, QuerySchemaAutoConfiguration::class], before = [ElasticsearchClientAutoConfiguration::class])

@ConditionalOnElasticsearchStorage

@ConditionalOnClass(value = [ElasticsearchEventStore::class])

@EnableConfigurationProperties(value = [ElasticsearchProperties::class, ElasticsearchQueryProperties::class, ElasticsearchEventStoreBatchProperties::class, ElasticsearchSnapshotStoreBatchProperties::class])

class ElasticsearchEventSourcingAutoConfiguration @Autowired constructor(elasticsearchProperties: ElasticsearchProperties, eventStoreBatchProperties: ElasticsearchEventStoreBatchProperties, snapshotStoreBatchProperties: ElasticsearchSnapshotStoreBatchProperties, queryProperties: ElasticsearchQueryProperties = ElasticsearchQueryProperties())

Constructors

ElasticsearchEventSourcingAutoConfiguration

@Autowired

constructor(elasticsearchProperties: ElasticsearchProperties, eventStoreBatchProperties: ElasticsearchEventStoreBatchProperties, snapshotStoreBatchProperties: ElasticsearchSnapshotStoreBatchProperties, queryProperties: ElasticsearchQueryProperties = ElasticsearchQueryProperties())

Functions

elasticsearchEventStore

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStore(elasticsearchClient: ReactiveElasticsearchClient, indexTemplateInitializer: IndexTemplateInitializer, metrics: ObjectProvider<WowMetrics>): ElasticsearchEventStore

elasticsearchEventStoreBinding

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStoreBinding(@Qualifier(value = "elasticsearchEventStore") eventStore: EventStore): EventStoreBinding

elasticsearchEventStreamQueryBackendFactory

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStreamQueryBackendFactory(elasticsearchClient: ReactiveElasticsearchClient, elasticsearchIndexMappingResolver: ElasticsearchIndexMappingResolver = ElasticsearchIndexMappingResolver(elasticsearchClient), sources: List<QuerySchemaSource> = emptyList()): ElasticsearchEventStreamQueryBackendFactory

elasticsearchEventStreamQueryBackendFactoryBinding

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStreamQueryBackendFactoryBinding(elasticsearchEventStreamQueryBackendFactory: ElasticsearchEventStreamQueryBackendFactory): EventStreamQueryBackendFactoryBinding

elasticsearchIndexMappingResolver

@Bean

@ConditionalOnMissingBean

fun elasticsearchIndexMappingResolver(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchIndexMappingResolver

elasticsearchSnapshotIndexInitializer

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotIndexInitializer(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchSnapshotIndexInitializer

elasticsearchSnapshotQueryBackendFactory

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotQueryBackendFactory(elasticsearchClient: ReactiveElasticsearchClient, elasticsearchIndexMappingResolver: ElasticsearchIndexMappingResolver, sources: List<QuerySchemaSource>): ElasticsearchSnapshotQueryBackendFactory

elasticsearchSnapshotQueryBackendFactoryBinding

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotQueryBackendFactoryBinding(elasticsearchSnapshotQueryBackendFactory: ElasticsearchSnapshotQueryBackendFactory): SnapshotQueryBackendFactoryBinding

elasticsearchSnapshotStore

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotStore(elasticsearchClient: ReactiveElasticsearchClient, indexTemplateInitializer: IndexTemplateInitializer, snapshotIndexInitializer: ElasticsearchSnapshotIndexInitializer, metrics: ObjectProvider<WowMetrics>): ElasticsearchSnapshotStore

elasticsearchSnapshotStoreBinding

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotStoreBinding(@Qualifier(value = "elasticsearchSnapshotStore") snapshotStore: SnapshotStore): SnapshotStoreBinding

indexTemplateInitializer

@Bean

fun indexTemplateInitializer(elasticsearchOperations: ReactiveElasticsearchOperations): IndexTemplateInitializer

jackson3JsonpMapper

@Bean

@ConditionalOnMissingBean(value = [JsonpMapper::class])

fun jackson3JsonpMapper(): Jackson3JsonpMapper

rest5ClientOptions

@Bean

@ConditionalOnProperty(value = ["wow.elasticsearch.compatibility-version"])

@ConditionalOnMissingBean(value = [Rest5ClientOptions::class])

fun rest5ClientOptions(): Rest5ClientOptions