[−][src]Struct elasticsearch::Reindex
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,
[src]
B: Body,
pub fn new(transport: &'a Transport) -> Self
[src]
Creates a new instance of Reindex
pub fn body<T>(self, body: T) -> Reindex<'a, 'b, JsonBody<T>> where
T: Serialize,
[src]
T: Serialize,
The body for the API call
pub fn error_trace(self, error_trace: bool) -> Self
[src]
Include the stack trace of returned errors.
pub fn filter_path(self, filter_path: &'b [&'b str]) -> Self
[src]
A comma-separated list of filters used to reduce the response.
pub fn header(self, key: HeaderName, value: HeaderValue) -> Self
[src]
Adds a HTTP header
pub fn human(self, human: bool) -> Self
[src]
Return human readable values for statistics.
pub fn max_docs(self, max_docs: i64) -> Self
[src]
Maximum number of documents to process (default: all documents)
pub fn pretty(self, pretty: bool) -> Self
[src]
Pretty format the returned JSON response.
pub fn refresh(self, refresh: bool) -> Self
[src]
Should the affected indexes be refreshed?
pub fn request_timeout(self, timeout: Duration) -> Self
[src]
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(self, requests_per_second: i64) -> Self
[src]
The throttle to set on this request in sub-requests per second. -1 means no throttle.
pub fn scroll(self, scroll: &'b str) -> Self
[src]
Control how long to keep the search context alive
pub fn slices(self, slices: Slices) -> Self
[src]
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(self, source: &'b str) -> Self
[src]
The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
pub fn timeout(self, timeout: &'b str) -> Self
[src]
Time each individual bulk request should wait for shards that are unavailable.
pub fn wait_for_active_shards(self, wait_for_active_shards: &'b str) -> Self
[src]
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(self, wait_for_completion: bool) -> Self
[src]
Should the request should block until the reindex is complete.
pub async fn send(self) -> Result<Response, Error>
[src]
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>
[src]
impl<'a, 'b, B: Debug> Debug for Reindex<'a, 'b, B>
[src]
Auto Trait Implementations
impl<'a, 'b, B> !RefUnwindSafe for Reindex<'a, 'b, B>
impl<'a, 'b, B> Send for Reindex<'a, 'b, B> where
B: Send,
B: Send,
impl<'a, 'b, B> Sync for Reindex<'a, 'b, B> where
B: Sync,
B: Sync,
impl<'a, 'b, B> Unpin for Reindex<'a, 'b, B> where
B: Unpin,
B: Unpin,
impl<'a, 'b, B> !UnwindSafe for Reindex<'a, 'b, B>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DynClone for T where
T: Clone,
[src]
T: Clone,
pub fn __clone_box(&self, Private) -> *mut ()
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,