Package dev.evo.elasticmagic.bulk

Types

Action
Link copied to clipboard
sealed class Action<S>
Content copied to clipboard
Base bulk action class.
ActionMeta
Link copied to clipboard
interface ActionMeta
Content copied to clipboard
Bulk action metadata.
ConcurrencyControl
Link copied to clipboard
enum ConcurrencyControl : Enum<ConcurrencyControl> , ToValue<String>
Content copied to clipboard
Controls optimistic concurrency.
CreateAction
Link copied to clipboard
class CreateAction<S : BaseDocSource>(meta: ActionMeta, source: S, pipeline: String?, concurrencyControl: ConcurrencyControl?) : IndexAction<S>
Content copied to clipboard
Creates new source document in an index.
DeleteAction
Link copied to clipboard
class DeleteAction(meta: IdActionMeta, concurrencyControl: ConcurrencyControl?) : Action<Nothing>
Content copied to clipboard
Removes a document specified by an meta's id from an index.
DocSourceAndMeta
Link copied to clipboard
class DocSourceAndMeta<M : ActionMeta>(meta: M, doc: BaseDocSource)
Content copied to clipboard
Combines a document source with its action metadata.
IdActionMeta
Link copied to clipboard
interface IdActionMeta : ActionMeta
Content copied to clipboard
Bulk action metadata with mandatory id.
IndexAction
Link copied to clipboard
open class IndexAction<S : BaseDocSource>(meta: ActionMeta, source: S, concurrencyControl: ConcurrencyControl?, pipeline: String?) : Action<S>
Content copied to clipboard
Indexes a source document to an index.
Refresh
Link copied to clipboard
enum Refresh : Enum<Refresh> , ToValue<String>
Content copied to clipboard
Refresh controls when changes will be searchable.
UpdateAction
Link copied to clipboard
class UpdateAction<S : BaseDocSource>(meta: IdActionMeta, source: UpdateSource<S>, retryOnConflict: Int?, concurrencyControl: ConcurrencyControl?) : Action<UpdateSource<S>>
Content copied to clipboard
Updates a document specified by an meta's id.
UpdateSource
Link copied to clipboard
sealed class UpdateSource<S : BaseDocSource>
Content copied to clipboard
Represents an update action's source.

Functions

withActionMeta
Link copied to clipboard
fun BaseDocSource.withActionMeta(routing: String? = null, version: Long? = null, seqNo: Long? = null, primaryTerm: Long? = null): DocSourceAndMeta<ActionMeta>
Content copied to clipboard
A shortcut to attach action metadata to a document source.
fun BaseDocSource.withActionMeta(id: String, routing: String? = null, version: Long? = null, seqNo: Long? = null, primaryTerm: Long? = null): DocSourceAndMeta<IdActionMeta>
Content copied to clipboard
A shortcut to attach action metadata to a document source.