Struct Search

Source
pub struct Search<'a, 'b, B> { /* private fields */ }
Expand description

Builder for the Search API

Returns results matching a query.

Implementations§

Source§

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

Source

pub fn new(transport: &'a Transport, parts: SearchParts<'b>) -> Self

Creates a new instance of Search with the specified API parts

Source

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

True or false to return the _source field or not, or a list of fields to return

Source

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

A list of fields to exclude from the returned _source field

Source

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

A list of fields to extract and return from the _source field

Source

pub fn allow_no_indices(self, allow_no_indices: bool) -> Self

Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes _all string or when no indices have been specified)

Source

pub fn allow_partial_search_results( self, allow_partial_search_results: bool, ) -> Self

Indicate if an error should be returned if there is a partial search failure or timeout

Source

pub fn analyze_wildcard(self, analyze_wildcard: bool) -> Self

Specify whether wildcard and prefix queries should be analyzed (default: false)

Source

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

The analyzer to use for the query string

Source

pub fn batched_reduce_size(self, batched_reduce_size: i64) -> Self

The number of shard results that should be reduced at once on the coordinating node. This value should be used as a protection mechanism to reduce the memory overhead per search request if the potential number of shards in the request can be large.

Source

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

The body for the API call

Source

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

Source

pub fn default_operator(self, default_operator: DefaultOperator) -> Self

The default operator for query string query (AND or OR)

Source

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

The field to use as default where no field prefix is given in the query string

Source

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

A comma-separated list of fields to return as the docvalue representation of a field for each hit

Source

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

Include the stack trace of returned errors.

Source

pub fn expand_wildcards(self, expand_wildcards: &'b [ExpandWildcards]) -> Self

Whether to expand wildcard expression to concrete indices that are open, closed or both.

Source

pub fn explain(self, explain: bool) -> Self

Specify whether to return detailed information about score computation as part of a hit

Source

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

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

Source

pub fn from(self, from: i64) -> Self

Starting offset (default: 0)

Source

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

Adds a HTTP header

Source

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

Return human readable values for statistics.

Source

pub fn ignore_throttled(self, ignore_throttled: bool) -> Self

Whether specified concrete, expanded or aliased indices should be ignored when throttled

Source

pub fn ignore_unavailable(self, ignore_unavailable: bool) -> Self

Whether specified concrete indices should be ignored when unavailable (missing or closed)

Source

pub fn lenient(self, lenient: bool) -> Self

Specify whether format-based query failures (such as providing text to a numeric field) should be ignored

Source

pub fn max_concurrent_shard_requests( self, max_concurrent_shard_requests: i64, ) -> Self

The number of concurrent shard requests per node this search executes concurrently. 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

Source

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

The minimum compatible version that all shards involved in search should have for this request to be successful

Source

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.

Source

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

Specify the node or shard the operation should be performed on (default: random)

Source

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

Pretty format the returned JSON response.

Source

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

Query in the Lucene query string syntax

Source

pub fn request_cache(self, request_cache: bool) -> Self

Specify if request cache should be used for this request or not, defaults to index level setting

Source

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.

Source

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

Source

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

A comma-separated list of specific routing values

Source

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

Specify how long a consistent view of the index should be maintained for scrolled search

Source

pub fn search_type(self, search_type: SearchType) -> Self

Search operation type

Source

pub fn seq_no_primary_term(self, seq_no_primary_term: bool) -> Self

Specify whether to return sequence number and primary term of the last modification of each hit

Source

pub fn size(self, size: i64) -> Self

Number of hits to return (default: 10)

Source

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

A comma-separated list of <field>:<direction> pairs

Source

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.

Source

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

Specific ‘tag’ of the request for logging and statistical purposes

Source

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

A comma-separated list of stored fields to return as part of a hit

Source

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

Specify which field to use for suggestions

Source

pub fn suggest_mode(self, suggest_mode: SuggestMode) -> Self

Specify suggest mode

Source

pub fn suggest_size(self, suggest_size: i64) -> Self

How many suggestions to return in response

Source

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

The source text for which the suggestions should be returned

Source

pub fn terminate_after(self, terminate_after: i64) -> Self

The maximum number of documents to collect for each shard, upon reaching which the query execution will terminate early.

Source

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

Explicit operation timeout

Source

pub fn track_scores(self, track_scores: bool) -> Self

Whether to calculate and return scores even if they are not used for sorting

Source

pub fn track_total_hits<T: Into<TrackTotalHits>>( self, track_total_hits: T, ) -> Self

Indicate if the number of documents that match the query should be tracked

Source

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

Source

pub fn version(self, version: bool) -> Self

Specify whether to return document version as part of a hit

Source

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

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

Trait Implementations§

Source§

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

Source§

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

Returns a copy of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

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

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a, 'b, B> Freeze for Search<'a, 'b, B>
where B: Freeze,

§

impl<'a, 'b, B> !RefUnwindSafe for Search<'a, 'b, B>

§

impl<'a, 'b, B> Send for Search<'a, 'b, B>
where B: Send,

§

impl<'a, 'b, B> Sync for Search<'a, 'b, B>
where B: Sync,

§

impl<'a, 'b, B> Unpin for Search<'a, 'b, B>
where B: Unpin,

§

impl<'a, 'b, B> !UnwindSafe for Search<'a, 'b, B>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

Source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

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
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,