Struct elasticsearch::Reindex

pub struct Reindex<'a, 'b, B> { /* fields omitted */ }

Builder for the Reindex API

Allows to copy documents from one index to another, optionally filtering the source documents by a query, changing the destination index settings, or fetching the documents from a remote cluster.

Implementations

impl<'a, 'b, B> Reindex<'a, 'b, B> where
    B: Body, 

pub fn new(transport: &'a Transport) -> Self

Creates a new instance of Reindex

pub fn body<T>(self, body: T) -> Reindex<'a, 'b, JsonBody<T>> where
    T: Serialize, 

The body for the API call

pub fn error_trace(mut self: Self, error_trace: bool) -> Self

Include the stack trace of returned errors.

pub fn filter_path(mut self: Self, filter_path: &'b [&'b str]) -> Self

A comma-separated list of filters used to reduce the response.

pub fn header(mut self: Self, key: HeaderName, value: HeaderValue) -> Self

Adds a HTTP header

pub fn human(mut self: Self, human: bool) -> Self

Return human readable values for statistics.

pub fn max_docs(mut self: Self, max_docs: i64) -> Self

Maximum number of documents to process (default: all documents)

pub fn pretty(mut self: Self, pretty: bool) -> Self

Pretty format the returned JSON response.

pub fn refresh(mut self: Self, refresh: bool) -> Self

Should the affected indexes be refreshed?

pub fn request_timeout(mut self: Self, timeout: Duration) -> Self

Sets a request timeout for this API call.

The timeout is applied from when the request starts connecting until the response body has finished.

pub fn requests_per_second(mut self: Self, requests_per_second: i64) -> Self

The throttle to set on this request in sub-requests per second. -1 means no throttle.

pub fn scroll(mut self: Self, scroll: &'b str) -> Self

Control how long to keep the search context alive

pub fn slices(mut self: Self, slices: Slices) -> Self

The number of slices this task should be divided into. Defaults to 1, meaning the task isn't sliced into subtasks. Can be set to auto.

pub fn source(mut self: Self, source: &'b str) -> Self

The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.

pub fn timeout(mut self: Self, timeout: &'b str) -> Self

Time each individual bulk request should wait for shards that are unavailable.

pub fn wait_for_active_shards(
    mut self: Self,
    wait_for_active_shards: &'b str
) -> Self

Sets the number of shard copies that must be active before proceeding with the reindex operation. Defaults to 1, meaning the primary shard only. Set to all for all shard copies, otherwise set to any non-negative value less than or equal to the total number of copies for the shard (number of replicas + 1)

pub fn wait_for_completion(mut self: Self, wait_for_completion: bool) -> Self

Should the request should block until the reindex is complete.

pub async fn send(self) -> Result<Response, Error>

Creates an asynchronous call to the Reindex API that can be awaited

Trait Implementations

impl<'a, 'b, B: Clone> Clone for Reindex<'a, 'b, B>

fn clone(&self) -> Reindex<'a, 'b, B>

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a, 'b, B: Debug> Debug for Reindex<'a, 'b, B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.