Struct QueryRequest 

pub struct QueryRequest<'a> { /* private fields */ }

Builder produced by Client::sql, Client::influxql, or Client::query; chain options, then .await (for a collected QueryResult) or .stream() (for a streaming BatchStream).

Implementations

impl<'a> QueryRequest<'a>

pub fn param(self, key: impl Into<String>, value: impl Into<Value>) -> Self

Add a single named parameter.

pub fn params<K, V, I>(self, params: I) -> Self

where I: IntoIterator<Item = (K, V)>, K: Into<String>, V: Into<Value>,

Add multiple named parameters from an iterable.

pub fn header(self, k: impl Into<String>, v: impl Into<String>) -> Self

Add a gRPC metadata header sent with the Flight DoGet request.

pub fn retry(self, policy: RetryConfig) -> Self

Override the retry policy for this query (defaults to the client’s).

pub fn no_retry(self) -> Self

Disable retries for this query.

pub async fn stream(self) -> Result<BatchStream>

Open the query as a streaming BatchStream instead of collecting. Use this for results too large to materialise in memory.

Only the connection setup is retried; once batches start arriving a stream can’t be replayed, so mid-stream errors propagate to the caller.

Trait Implementations

impl<'a> IntoFuture for QueryRequest<'a>

type Output = Result<QueryResult, Error>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <QueryRequest<'a> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.