Struct influxdb::Client

pub struct Client { /* private fields */ }

Internal Representation of a Client

Implementations

impl Client

pub fn new<S1, S2>(url: S1, database: S2) -> Self where
    S1: Into<String>,
    S2: Into<String>, 

Instantiates a new Client

Arguments

• url: The URL where InfluxDB is running (ex. http://localhost:8086).
• database: The Database against which queries and writes will be run.

Examples

use influxdb::Client;

let _client = Client::new("http://localhost:8086", "test");

pub fn with_auth<S1, S2>(self, username: S1, password: S2) -> Self where
    S1: Into<String>,
    S2: Into<String>, 

Add authentication/authorization information to Client

Arguments

• username: The Username for InfluxDB.
• password: THe Password for the user.

Examples

use influxdb::Client;

let _client = Client::new("http://localhost:9086", "test").with_auth("admin", "password");

pub fn database_name(&self) -> &str

Returns the name of the database the client is using

pub fn database_url(&self) -> &str

Returns the URL of the InfluxDB installation the client is using

pub async fn ping(&self) -> Result<(String, String), Error>

Pings the InfluxDB Server

Returns a tuple of build type and version number

pub async fn query<'q, Q>(&self, q: &'q Q) -> Result<String, Error> where
    Q: Query,
    &'q Q: Into<QueryTypes<'q>>, 

Sends a ReadQuery or WriteQuery to the InfluxDB Server.

A version capable of parsing the returned string is available under the serde_integration

Arguments

• q: Query of type ReadQuery or WriteQuery

Examples

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

let client = Client::new("http://localhost:8086", "test");
let query = Timestamp::Now
    .into_query("weather")
    .add_field("temperature", 82);
let results = client.query(&query).await?;

Errors

If the function can not finish the query, a Error variant will be returned.

impl Client

pub async fn json_query(
    &self,
    q: ReadQuery
) -> Result<DatabaseQueryResult, Error>

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.

impl Into<Vec<(String, String), Global>> for Client

fn into(self) -> Vec<(String, String)>

Performs the conversion.

impl<'a> Into<Vec<(String, String), Global>> for &'a Client

fn into(self) -> Vec<(String, String)>

Performs the conversion.