rinflux is Rust based influx client implementation that have been inspired from influx other language implementation, developed with 💖

Workfoxes

Last update: Apr 7, 2022

Related tags

Overview

Unofficial InfluxDB Driver for Rust

This library is a work in progress. This means a feature you might need is not implemented yet or could be handled better.

Pull requests are always welcome. See Contributing and Code of Conduct. For a list of past changes, see CHANGELOG.md.

Currently, Supported Features

Reading and Writing to InfluxDB
Optional Serde Support for Deserialization
Running multiple queries in one request (e.g. SELECT * FROM weather_berlin; SELECT * FROM weather_london)
Authenticated and Unauthenticated Connections
async/await support
#[derive(InfluxDbWriteable)] Derive Macro for Writing / Reading into Structs
GROUP BY support
Tokio and async-std support (see example below) or available backends
Swappable HTTP backends (see below)

Quickstart

Add the following to your Cargo.toml

rinflux = { version = "0.1.0", git = "https://github.com/workfoxes/rinflux.git" }

For an example with using Serde deserialization, please refer to serde_integration

use rinflux::{Client, Query, Timestamp, ReadQuery};
use rinflux::InfluxDbWriteable;
use chrono::{DateTime, Utc};

#[tokio::main]
// or #[async_std::main] if you prefer
async fn main() {
    // Connect to db `test` on `http://localhost:8086`
    let client = Client::new("http://localhost:8086", "test");

    #[derive(InfluxDbWriteable)]
    struct WeatherReading {
        time: DateTime<Utc>,
        humidity: i32,
        #[influxdb(tag)] wind_direction: String,
    }

    // Let's write some data into a measurement called `weather`
    let weather_reading = WeatherReading {
        time: Timestamp::Hours(1).into(),
        humidity: 30,
        wind_direction: String::from("north"),
    };

    let write_result = client
        .query(weather_reading.into_query("weather"))
        .await;
    assert!(write_result.is_ok(), "Write result was not okay");

    // Let's see if the data we wrote is there
    let read_query = ReadQuery::new("SELECT * FROM weather");

    let read_result = client.query(read_query).await;
    assert!(read_result.is_ok(), "Read result was not ok");
    println!("{}", read_result.unwrap());
}

License

@ 2022 Workfoxes and contributors.

Incomplete Redis client and server implementation using Tokio - for learning purposes only

mini-redis mini-redis is an incomplete, idiomatic implementation of a Redis client and server built with Tokio. The intent of this project is to provi

2.3k Jan 4, 2023

🦀 REST API client implementation for freee, auto-generated from OpenAPI specification.

freee-rs REST API client implementation for freee, auto-generated from OpenAPI specification. Getting Started Add to your Cargo.toml as follows: [depe

3 Jul 14, 2022

Python implementation of CeresDB client.

CeresDB Python Client Introduction The python client for CeresDB. CeresDB is a high-performance, distributed, schema-less, cloud native time-series da

6 Feb 28, 2023

A Rust client for the ElasticSearch REST API

rs-es Introduction An ElasticSearch client for Rust via the REST API. Targetting ElasticSearch 2.0 and higher. Other clients For later versions of Ela

218 Dec 27, 2022

An Elasticsearch REST API client for Rust

elastic elastic is an efficient, modular API client for Elasticsearch written in Rust. The API is targeting the Elastic Stack 7.x. elastic provides st

249 Oct 18, 2022

An etcd client library for Rust.

etcd An etcd client library for Rust. etcd on crates.io Documentation for the latest crates.io release Running the tests Install Docker and Docker Com

138 Dec 27, 2022

Mysql client library implemented in rust.

mysql This crate offers: MySql database driver in pure rust; connection pool. Features: macOS, Windows and Linux support; TLS support via nativetls cr

548 Dec 31, 2022

Telegram bot API client for Rust

Frankenstein Telegram bot API client for Rust. It's a complete wrapper for Telegram bot API and it's up to date with version 5.2 of the API. Frankenst