wow-elasticsearch/me.ahoo.wow.elasticsearch.eventsourcing

Package-level declarations

Types

class ElasticsearchBulkItemException(val operationType: OperationType, val index: String, val id: String?, val status: Int, val error: ErrorCause?) : RuntimeException

ElasticsearchBulkResponseException

class ElasticsearchBulkResponseException(message: String) : RuntimeException

ElasticsearchEventStore

class ElasticsearchEventStore(elasticsearchClient: ReactiveElasticsearchClient, val batchOptions: ElasticsearchEventStoreBatchOptions = ElasticsearchEventStoreBatchOptions(), refreshPolicy: Refresh = Refresh.True, batchSize: Int = DEFAULT_BATCH_SIZE, metrics: WowMetrics = WowMetrics.NONE) : AbstractEventStore

ElasticsearchEventStoreBatchCloseTimeoutException

class ElasticsearchEventStoreBatchCloseTimeoutException(val timeout: Duration) : IllegalStateException

ElasticsearchEventStoreBatchOptions

data class ElasticsearchEventStoreBatchOptions(val enabled: Boolean = false, val maxSize: Int = DEFAULT_MAX_SIZE, val maxDelay: Duration = DEFAULT_MAX_DELAY, val maxPendingAppends: Int = DEFAULT_MAX_PENDING_APPENDS, val laneCount: Int = DEFAULT_LANE_COUNT)

Controls transparent batching for ElasticsearchEventStore appends.

ElasticsearchEventStoreBatchOverflowException

class ElasticsearchEventStoreBatchOverflowException(val maxPendingAppends: Int) : IllegalStateException, RecoverableException

ElasticsearchSnapshotStore

class ElasticsearchSnapshotStore(elasticsearchClient: ReactiveElasticsearchClient, val batchOptions: ElasticsearchSnapshotStoreBatchOptions = ElasticsearchSnapshotStoreBatchOptions(), refreshPolicy: Refresh = Refresh.True, metrics: WowMetrics = WowMetrics.NONE) : SnapshotStore

ElasticsearchSnapshotStoreBatchCloseTimeoutException

class ElasticsearchSnapshotStoreBatchCloseTimeoutException(val timeout: Duration) : IllegalStateException

ElasticsearchSnapshotStoreBatchOptions

data class ElasticsearchSnapshotStoreBatchOptions(val enabled: Boolean = false, val maxSize: Int = DEFAULT_MAX_SIZE, val maxDelay: Duration = DEFAULT_MAX_DELAY, val maxPendingSaves: Int = DEFAULT_MAX_PENDING_SAVES, val laneCount: Int = DEFAULT_LANE_COUNT)

Controls transparent batching for ElasticsearchSnapshotStore saves.

ElasticsearchSnapshotStoreBatchOverflowException

class ElasticsearchSnapshotStoreBatchOverflowException(val maxPendingSaves: Int) : IllegalStateException, RecoverableException