Struct influxdb::WriteQuery

pub struct WriteQuery { /* private fields */ }

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

Implementations

impl WriteQuery

pub fn new<S>(timestamp: Timestamp, measurement: S) -> Selfwhere
    S: Into<String>,

Creates a new WriteQuery

pub fn add_field<S, F>(self, field: S, value: F) -> Selfwhere
    S: Into<String>,
    F: WriteType,

Adds a field to the WriteQuery

Examples

use influxdb::{Query, Timestamp};
use influxdb::InfluxDbWriteable;

Timestamp::Nanoseconds(0).into_query("measurement").add_field("field1", 5).build();

pub fn add_tag<S, I>(self, tag: S, value: I) -> Selfwhere
    S: Into<String>,
    I: WriteType,

Adds a tag to the WriteQuery

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

Examples

use influxdb::{Query, Timestamp};
use influxdb::InfluxDbWriteable;

Timestamp::Nanoseconds(0)
    .into_query("measurement")
    .add_tag("field1", 5); // calling `.build()` now would result in a `Err(Error::InvalidQueryError)`

pub fn get_precision(&self) -> String

Trait Implementations

impl Clone for WriteQuery

fn clone(&self) -> WriteQuery

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WriteQuery

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

Formats the value using the given formatter.

impl Query for WriteQuery

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

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