Struct influx_client::blocking::Client

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

Use a Client to connect to your influx database and execute queries.

Implementations

impl<'a> Client<'a>

pub fn new(url: &'a str, token: &'a str) -> Self

Create a client with a given database URL and token.

pub fn from_env(url: &'a str) -> Result<Self, InfluxError>

Create a client that reads its token from the INFLUXDB_TOKEN environment variable

pub fn insert<T: Display>(
    &self,
    bucket: &'a str,
    org: &'a str,
    precision: Precision,
    query: WriteQuery<'_, T>
) -> Result<(), InfluxError>

Insert a new value into a bucket. Note that not all attributes on WriteQuery are supported yet.

pub fn get(
    &self,
    org: &'a str,
    query: ReadQuery<'_>
) -> Result<String, InfluxError>

Retrieve a value from a bucket based on certain filters.

pub fn get_csv(
    &self,
    org: &'a str,
    query: ReadQuery<'_>
) -> Result<Vec<StringRecord>, InfluxError>

pub fn get_raw(&self, org: &'a str, query: &'a str) -> Result<String, InfluxError>

If you prefer to write your own flux queries, use this method. As flux support is not complete yet, this is currently the only way to use the full flux language.