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 each_s(self, each_s: f64) -> Self

👎Deprecated since 1.15.0: Use $each_t operator in when condition. It will be removed in v1.18.0.

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

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

👎Deprecated since 1.15.0: Use $each_n operator in when condition. It will be removed in v1.18.0.

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

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

👎Deprecated since 1.15.0: Use $limit operator in when condition. It will be removed in v1.18.0.

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.