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

ElasticsearchEventSourcingAutoConfiguration

@AutoConfiguration(after = [ElasticsearchRestClientAutoConfiguration::class])

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

@EnableConfigurationProperties(value = [ElasticsearchProperties::class])

class ElasticsearchEventSourcingAutoConfiguration(elasticsearchProperties: ElasticsearchProperties)

Constructors

ElasticsearchEventSourcingAutoConfiguration

constructor(elasticsearchProperties: ElasticsearchProperties)

Functions

elasticsearchEventStore

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStore(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchEventStore

elasticsearchEventStoreBinding

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

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

elasticsearchEventStreamQueryServiceFactory

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStreamQueryServiceFactory(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchEventStreamQueryServiceFactory

elasticsearchEventStreamQueryServiceFactoryBinding

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStreamQueryServiceFactoryBinding(elasticsearchEventStreamQueryServiceFactory: ElasticsearchEventStreamQueryServiceFactory): EventStreamQueryServiceFactoryBinding

elasticsearchSnapshotQueryServiceFactory

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotQueryServiceFactory(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchSnapshotQueryServiceFactory

elasticsearchSnapshotQueryServiceFactoryBinding

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotQueryServiceFactoryBinding(elasticsearchSnapshotQueryServiceFactory: ElasticsearchSnapshotQueryServiceFactory): SnapshotQueryServiceFactoryBinding

elasticsearchSnapshotStore

@Bean(name = ["elasticsearchSnapshotStore", "elasticsearchSnapshotRepository"])

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchSnapshotStore(elasticsearchClient: ReactiveElasticsearchClient): ElasticsearchSnapshotStore

elasticsearchSnapshotStoreBinding

@Bean

@ConditionalOnSnapshotStoreStorage(value = StorageType.ELASTICSEARCH)

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

indexTemplateInitializer

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun indexTemplateInitializer(elasticsearchOperations: ReactiveElasticsearchOperations): IndexTemplateInitializer

jackson3JsonpMapper

@Bean

fun jackson3JsonpMapper(): Jackson3JsonpMapper