Struct influxdb::query::write_query::InfluxDbWriteQuery

pub struct InfluxDbWriteQuery { /* private fields */ }

Internal Representation of a Write query that has not yet been built

Implementations

impl InfluxDbWriteQuery

pub fn new<S>(timestamp: Timestamp, measurement: S) -> Self where
    S: ToString, 

Creates a new InfluxDbWriteQuery

pub fn add_field<S, I>(self, tag: S, value: I) -> Self where
    S: ToString,
    I: Into<InfluxDbType>, 

Adds a field to the InfluxDbWriteQuery

Examples

use influxdb::query::{InfluxDbQuery, Timestamp};

InfluxDbQuery::write_query(Timestamp::NOW, "measurement").add_field("field1", 5).build();

pub fn add_tag<S, I>(self, tag: S, value: I) -> Self where
    S: ToString,
    I: Into<InfluxDbType>, 

Adds a tag to the InfluxDbWriteQuery

Please note that a InfluxDbWriteQuery requires at least one field. Composing a query with only tags will result in a failure building the query.

Examples

use influxdb::query::{InfluxDbQuery, Timestamp};

InfluxDbQuery::write_query(Timestamp::NOW, "measurement")
    .add_tag("field1", 5); // calling `.build()` now would result in a `Err(InfluxDbError::InvalidQueryError)`

pub fn get_precision(&self) -> String

Trait Implementations

impl InfluxDbQuery for InfluxDbWriteQuery

fn build(&self) -> Result<ValidQuery, InfluxDbError>

Builds valid InfluxSQL which can be run against the Database. In case no fields have been specified, it will return an error, as that is invalid InfluxSQL syntax.

fn get_type(&self) -> QueryType