Struct influxdb::client::InfluxDbClient

pub struct InfluxDbClient { /* fields omitted */ }

Internal Representation of a Client

Methods

impl InfluxDbClient

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

Instantiates a new InfluxDbClient

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::InfluxDbClient;

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

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 fn ping(
    &self
) -> impl Future<Item = (String, String), Error = InfluxDbError>

Pings the InfluxDB Server

Returns a tuple of build type and version number

pub fn query<Q>(
    &self,
    q: &Q
) -> Box<dyn Future<Item = String, Error = InfluxDbError>> where
    Q: Any + InfluxDbQuery, 

Sends a InfluxDbReadQuery or InfluxDbWriteQuery to the InfluxDB Server.InfluxDbError

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

Arguments

• q: Query of type InfluxDbReadQuery or InfluxDbWriteQuery

Examples

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

let client = InfluxDbClient::new("http://localhost:8086", "test");
let _future = client.query(
    &InfluxDbQuery::write_query(Timestamp::NOW, "weather")
        .add_field("temperature", 82)
);

impl InfluxDbClient

pub fn json_query(
    &self,
    q: InfluxDbReadQuery
) -> impl Future<Item = DatabaseQueryResult, Error = InfluxDbError>