Struct Client

pub struct Client { /* private fields */ }

A client for sending data with Influx Line Protocol queries in a convenient way

use url::Url;
use rinfluxdb_lineprotocol::LineBuilder;
use rinfluxdb_lineprotocol::r#async::Client;

# async_std::task::block_on(async {
let client = Client::new(
    Url::parse("https://example.com/")?,
    Some(("username", "password")),
)?;

let lines = vec![
    LineBuilder::new("measurement")
        .insert_field("field", 42.0)
        .build(),
    LineBuilder::new("measurement")
        .insert_field("field", 43.0)
        .insert_tag("tag", "value")
        .build(),
];

client.send("database", &lines).await?;
# Ok::<(), rinfluxdb_lineprotocol::ClientError>(())
# })?;
# Ok::<(), rinfluxdb_lineprotocol::ClientError>(())

Implementations

impl Client

pub fn new<T, S>( base_url: Url, credentials: Option<(T, S)>, ) -> Result<Self, ClientError>

where T: Into<String>, S: Into<String>,

Create a new client to an InfluxDB server

Parameter credentials can be used to provide username and password if the server requires authentication.

pub async fn send( &self, database: &str, lines: &[Line], ) -> Result<(), ClientError>

Sends data using the Influx Line Protocol

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.