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

ElasticsearchEventSourcingAutoConfiguration

@AutoConfiguration(after = [ElasticsearchRestClientAutoConfiguration::class, QuerySchemaAutoConfiguration::class], before = [ElasticsearchClientAutoConfiguration::class, QueryAutoConfiguration::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(), indexNamingProvider: ObjectProvider<ElasticsearchIndexNaming>?)

Constructors

ElasticsearchEventSourcingAutoConfiguration

@Autowired

constructor(elasticsearchProperties: ElasticsearchProperties, eventStoreBatchProperties: ElasticsearchEventStoreBatchProperties, snapshotStoreBatchProperties: ElasticsearchSnapshotStoreBatchProperties, queryProperties: ElasticsearchQueryProperties = ElasticsearchQueryProperties(), indexNamingProvider: ObjectProvider<ElasticsearchIndexNaming>?)

The constructor from before the index prefix, kept for binary compatibility: names from the properties.

Functions

elasticsearchEventStore

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

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

elasticsearchEventStoreBinding

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

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

elasticsearchEventStoreRuntimeResource

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStoreRuntimeResource(@Qualifier(value = "elasticsearchEventStore") elasticsearchEventStore: EventStore): RuntimeResource

elasticsearchEventStreamIndexInitializer

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStreamIndexInitializer(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchEventStreamIndexInitializer

elasticsearchEventStreamQueryBackendFactory

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStreamQueryBackendFactory(elasticsearchClient: ReactiveElasticsearchClient, elasticsearchIndexMappingResolver: ElasticsearchIndexMappingResolver = ElasticsearchIndexMappingResolver(elasticsearchClient)): ElasticsearchEventStreamQueryBackendFactory

elasticsearchEventStreamQueryBackendProvider

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStreamQueryBackendProvider(elasticsearchEventStreamQueryBackendFactory: ElasticsearchEventStreamQueryBackendFactory): QueryBackendProvider

elasticsearchIndexMappingResolver

@Bean

@ConditionalOnMissingBean

fun elasticsearchIndexMappingResolver(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchIndexMappingResolver

elasticsearchIndexNaming

@Bean

@ConditionalOnMissingBean

fun elasticsearchIndexNaming(): ElasticsearchIndexNaming

elasticsearchSnapshotIndexInitializer

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotIndexInitializer(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchSnapshotIndexInitializer

elasticsearchSnapshotQueryBackendFactory

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotQueryBackendFactory(elasticsearchClient: ReactiveElasticsearchClient, elasticsearchIndexMappingResolver: ElasticsearchIndexMappingResolver): ElasticsearchSnapshotQueryBackendFactory

elasticsearchSnapshotQueryBackendProvider

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotQueryBackendProvider(elasticsearchSnapshotQueryBackendFactory: ElasticsearchSnapshotQueryBackendFactory): QueryBackendProvider

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

elasticsearchSnapshotStoreRuntimeResource

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotStoreRuntimeResource(@Qualifier(value = "elasticsearchSnapshotStore") elasticsearchSnapshotStore: SnapshotStore): RuntimeResource

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