Struct QueryBuilder

pub struct QueryBuilder { /* private fields */ }

Builder for a query request.

Implementations

impl QueryBuilder

pub fn start(self, time: SystemTime) -> Self

Set the start time of the query.

pub fn start_us(self, time_us: u64) -> Self

Set the start time of the query as a unix timestamp in microseconds.

pub fn stop(self, time: SystemTime) -> Self

Set the end time of the query.

pub fn stop_us(self, time_us: u64) -> Self

Set the end time of the query as a unix timestamp in microseconds.

pub fn when(self, condition: Value) -> Self

Set the condition for the query.

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

Set the query to be strict. If the query is strict, the query will return an error if any of the conditions are invalid. default: false

pub fn ext(self, ext: Value) -> Self

Set extension parameters for the query. This is a JSON object that will be passed to extensions on the server side.

pub fn include(self, labels: Labels) -> Self

👎Deprecated since 1.13.0: Use the when method to set the labels to include in the query.

Set the labels to include in the query.

pub fn add_include<Str>(self, key: Str, value: Str) -> Self

where Str: Into<String>,

👎Deprecated since 1.13.0: Use the when method to set the labels to exclude from the query.

Add a label to include in the query.

pub fn exclude(self, labels: Labels) -> Self

👎Deprecated since 1.13.0: Use the when method to set the labels to exclude from the query.

Set the labels to exclude from the query.

pub fn add_exclude<Str>(self, key: Str, value: Str) -> Self

where Str: Into<String>,

👎Deprecated since 1.13.0: Use the when method to add a label to exclude from the query.

Add a label to exclude from the query.

pub fn each_s(self, each_s: f64) -> Self

Set S, to return a record every S seconds. default: return all records

pub fn each_n(self, each_n: u64) -> Self

Set N, to return every N records. default: return all records

pub fn limit(self, limit: u64) -> Self

Set a limit for the query. default: unlimited

pub fn ttl(self, ttl: Duration) -> Self

Set TTL for the query.

pub fn continuous(self) -> Self

Set the query to be continuous.

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

Set the query to head only. default: false

pub async fn send( self, ) -> Result<impl Stream<Item = Result<Record, ReductError>>, ReductError>

Send the query request.