elasticmagic/dev.evo.elasticmagic.bulk

Package-level declarations

Types

sealed class Action<S>

Base bulk action class.

Bulk action metadata.

Controls optimistic concurrency.

class CreateAction<S : BaseDocSource>( meta: ActionMeta, source: S, pipeline: String? = null, concurrencyControl: ConcurrencyControl? = null) : IndexAction<S>

Creates new source document in an index. If the document already exists, the action fails.

class DeleteAction(val meta: IdActionMeta, val concurrencyControl: ConcurrencyControl? = null) : Action<Nothing>

Removes a document specified by an meta's id from an index.

Combines a document source with its action metadata.

Bulk action metadata with mandatory id.

open class IndexAction<S : BaseDocSource>( val meta: ActionMeta, val source: S, val concurrencyControl: ConcurrencyControl? = null, val pipeline: String? = null) : Action<S>

Indexes a source document to an index. If the document already exists, the action overwrites the document and increments its version.

class UpdateAction<S : BaseDocSource>( val meta: IdActionMeta, val source: UpdateSource<S>, val retryOnConflict: Int? = null, val concurrencyControl: ConcurrencyControl? = null) : Action<UpdateSource<S>>

Updates a document specified by an meta's id.

Represents an update action's source. Has 2 flavors:

fun BaseDocSource.withActionMeta( routing: String? = null, version: Long? = null, seqNo: Long? = null, primaryTerm: Long? = null): DocSourceAndMeta<ActionMeta>

fun BaseDocSource.withActionMeta( id: String, routing: String? = null, version: Long? = null, seqNo: Long? = null, primaryTerm: Long? = null): DocSourceAndMeta<IdActionMeta>

A shortcut to attach action metadata to a document source.