Struct elasticsearch::Msearch
source · [−]pub struct Msearch<'a, 'b, B> { /* private fields */ }
Expand description
Builder for the Msearch API
Allows to execute several search operations in one request.
Implementations
sourceimpl<'a, 'b, B> Msearch<'a, 'b, B> where
B: Body,
impl<'a, 'b, B> Msearch<'a, 'b, B> where
B: Body,
sourcepub fn new(transport: &'a Transport, parts: MsearchParts<'b>) -> Self
pub fn new(transport: &'a Transport, parts: MsearchParts<'b>) -> Self
Creates a new instance of Msearch with the specified API parts
sourcepub fn body<T>(self, body: Vec<T>) -> Msearch<'a, 'b, NdBody<T>> where
T: Body,
pub fn body<T>(self, body: Vec<T>) -> Msearch<'a, 'b, NdBody<T>> where
T: Body,
The body for the API call
sourcepub fn ccs_minimize_roundtrips(self, ccs_minimize_roundtrips: bool) -> Self
pub fn ccs_minimize_roundtrips(self, ccs_minimize_roundtrips: bool) -> Self
Indicates whether network round-trips should be minimized as part of cross-cluster search requests execution
sourcepub fn error_trace(self, error_trace: bool) -> Self
pub fn error_trace(self, error_trace: bool) -> Self
Include the stack trace of returned errors.
sourcepub fn filter_path(self, filter_path: &'b [&'b str]) -> Self
pub fn filter_path(self, filter_path: &'b [&'b str]) -> Self
A comma-separated list of filters used to reduce the response.
sourcepub fn header(self, key: HeaderName, value: HeaderValue) -> Self
pub fn header(self, key: HeaderName, value: HeaderValue) -> Self
Adds a HTTP header
sourcepub fn max_concurrent_searches(self, max_concurrent_searches: i64) -> Self
pub fn max_concurrent_searches(self, max_concurrent_searches: i64) -> Self
Controls the maximum number of concurrent searches the multi search api will execute
sourcepub fn max_concurrent_shard_requests(
self,
max_concurrent_shard_requests: i64
) -> Self
pub fn max_concurrent_shard_requests(
self,
max_concurrent_shard_requests: i64
) -> Self
The number of concurrent shard requests each sub search executes concurrently per node. This value should be used to limit the impact of the search on the cluster in order to limit the number of concurrent shard requests
sourcepub fn pre_filter_shard_size(self, pre_filter_shard_size: i64) -> Self
pub fn pre_filter_shard_size(self, pre_filter_shard_size: i64) -> Self
A threshold that enforces a pre-filter roundtrip to prefilter search shards based on query rewriting if the number of shards the search request expands to exceeds the threshold. This filter roundtrip can limit the number of shards significantly if for instance a shard can not match any documents based on its rewrite method ie. if date filters are mandatory to match but the shard bounds and the query are disjoint.
sourcepub fn request_timeout(self, timeout: Duration) -> Self
pub fn request_timeout(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.
sourcepub fn rest_total_hits_as_int(self, rest_total_hits_as_int: bool) -> Self
pub fn rest_total_hits_as_int(self, rest_total_hits_as_int: bool) -> Self
Indicates whether hits.total should be rendered as an integer or an object in the rest search response
sourcepub fn search_type(self, search_type: SearchType) -> Self
pub fn search_type(self, search_type: SearchType) -> Self
Search operation type
sourcepub fn source(self, source: &'b str) -> Self
pub fn source(self, source: &'b str) -> Self
The URL-encoded request definition. Useful for libraries that do not accept a request body for non-POST requests.
sourcepub fn typed_keys(self, typed_keys: bool) -> Self
pub fn typed_keys(self, typed_keys: bool) -> Self
Specify whether aggregation and suggester names should be prefixed by their respective types in the response
Trait Implementations
Auto Trait Implementations
impl<'a, 'b, B> !RefUnwindSafe for Msearch<'a, 'b, B>
impl<'a, 'b, B> Send for Msearch<'a, 'b, B> where
B: Send,
impl<'a, 'b, B> Sync for Msearch<'a, 'b, B> where
B: Sync,
impl<'a, 'b, B> Unpin for Msearch<'a, 'b, B> where
B: Unpin,
impl<'a, 'b, B> !UnwindSafe for Msearch<'a, 'b, B>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more