Struct 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 async fn insert<T: Display>( &self, bucket: &'a str, org: &'a str, precision: Precision, query: WriteQuery<'a, T>, ) -> Result<(), InfluxError>

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

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

Retrieve a value from a bucket based on certain filters.

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

pub async 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.