Struct Client 

pub struct Client { /* private fields */ }

Async client for InfluxDB 3 Core and Enterprise.

See the crate-level docs for end-to-end examples.

Implementations

impl Client

pub async fn new(config: ClientConfig) -> Result<Self>

Create a client from a ClientConfig.

The Arrow Flight gRPC channel is opened lazily on the first query call, so this constructor never fails due to gRPC connectivity.

pub async fn from_connection_string(cs: &str) -> Result<Self>

Parse a connection string and create a client.

pub async fn from_env() -> Result<Self>

Read INFLUX_HOST, INFLUX_TOKEN, and INFLUX_DATABASE from the environment and create a client.

pub fn config(&self) -> &ClientConfig

Return a reference to the underlying config.

pub fn write<W: WriteInput>(&self, data: W) -> WriteRequest<'_, W>

Start a write request.

data may be any WriteInput: a &str / String of pre-formatted line protocol, a Vec<Point> / &[Point], a DataFrameWrite (polars feature), or your own type that implements the trait.

Returns a WriteRequest builder; chain options, then .await. See the crate-level docs for examples.

pub fn sql(&self, q: impl Into<String>) -> QueryRequest<'_>

Start a SQL query. Sugar for query(q, QueryType::Sql).

pub fn influxql(&self, q: impl Into<String>) -> QueryRequest<'_>

Start an InfluxQL query. Sugar for query(q, QueryType::InfluxQL).

pub fn query( &self, q: impl Into<String>, language: QueryType, ) -> QueryRequest<'_>

Start a query. Returns a QueryRequest builder.

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

Ping the server and return its version string.