Skip to main content

ClientConfig

Struct ClientConfig 

Source
pub struct ClientConfig {
Show 14 fields pub host: String, pub token: Option<String>, pub auth_scheme: String, pub database: String, pub org: Option<String>, pub write_options: WriteOptions, pub retry: RetryConfig, pub headers: HeaderMap, pub ssl_roots_path: Option<String>, pub proxy: Option<String>, pub write_timeout: Duration, pub query_timeout: Duration, pub idle_connection_timeout: Duration, pub max_idle_connections: usize,
}
Expand description

Configuration for the InfluxDB 3 client.

Construct with ClientConfig::builder() or parse from a connection string / environment variables with ClientConfig::from_connection_string() / ClientConfig::from_env().

Fields§

§host: String

InfluxDB host URL (e.g. https://cluster.influxdata.io).

§token: Option<String>

API token.

§auth_scheme: String

Authentication scheme: "Bearer" (default) or "Token".

§database: String

Database for all operations. Required; validated at construction time.

§org: Option<String>

Organization name (used for v2 API compatibility).

§write_options: WriteOptions

Default write options applied to every write call.

§retry: RetryConfig

Default retry policy for transient write/query failures. Override per request with WriteRequest/QueryRequest .retry() / .no_retry().

§headers: HeaderMap

Extra HTTP headers sent with every request.

§ssl_roots_path: Option<String>

Path to a PEM file with additional CA roots for TLS verification.

§proxy: Option<String>

HTTP proxy URL.

§write_timeout: Duration

Request timeout for write calls.

§query_timeout: Duration

Timeout for the Flight channel connect and for collected (.await) queries. Streaming queries (.stream()) are intentionally unbounded.

§idle_connection_timeout: Duration

Keep-alive idle connection timeout.

§max_idle_connections: usize

Maximum number of idle connections in the pool.

Implementations§

Source§

impl ClientConfig

Source

pub fn builder() -> ClientConfigBuilder

Start building a config.

Source

pub fn from_env() -> Result<Self, Error>

Parse INFLUX_HOST, INFLUX_TOKEN, INFLUX_DATABASE, and INFLUX_ORG from the process environment. INFLUX_HOST and INFLUX_DATABASE are required; token and org are optional.

Source

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

Parse a URL-formatted connection string, e.g.:

https://cluster.influxdata.io/?token=TOKEN&database=DB&org=ORG

database (or bucket) is required; returns an error if absent.

Source

pub fn host_url(&self) -> &str

Return the normalised host URL (trailing slash stripped).

Source

pub fn authorization_header(&self) -> Result<Option<HeaderValue>, Error>

Build the Authorization header value ("Bearer TOKEN" etc.).

Returns Ok(None) when no token is set. Returns an error if the token contains characters that are invalid in an HTTP header value.

Trait Implementations§

Source§

impl Clone for ClientConfig

Source§

fn clone(&self) -> ClientConfig

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for ClientConfig

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for ClientConfig

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more