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

ElasticsearchEventSourcingAutoConfiguration

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

@ConditionalOnElasticsearchStorage

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

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

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

Constructors

ElasticsearchEventSourcingAutoConfiguration

@Autowired

constructor(elasticsearchProperties: ElasticsearchProperties, eventStoreBatchProperties: ElasticsearchEventStoreBatchProperties, snapshotStoreBatchProperties: ElasticsearchSnapshotStoreBatchProperties)

constructor(elasticsearchProperties: ElasticsearchProperties)

Functions

elasticsearchEventStore

@Bean

@ConditionalOnEventStoreStorage(value = StorageType.ELASTICSEARCH)

fun elasticsearchEventStore(elasticsearchClient: ReactiveElasticsearchClient, indexTemplateInitializer: IndexTemplateInitializer): 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, indexTemplateInitializer: IndexTemplateInitializer): 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