@spec add_connection(
  atom(),
  keyword()
) :: {:ok, pid()} | {:error, term()}

Adds a new named connection dynamically at runtime.

@spec client() :: module()

Returns the configured client implementation module.

@spec create_bucket(
  InfluxElixir.Client.connection(),
  binary(),
  keyword()
) :: :ok | {:error, term()}

Creates a bucket in InfluxDB v2 (backwards compatibility).

@spec create_database(
  InfluxElixir.Client.connection(),
  binary(),
  keyword()
) :: :ok | {:error, term()}

Creates a database in InfluxDB v3.

@spec create_token(
  InfluxElixir.Client.connection(),
  binary(),
  keyword()
) :: {:ok, map()} | {:error, term()}

Creates an API token in InfluxDB v3.

@spec delete_bucket(InfluxElixir.Client.connection(), binary()) ::
  :ok | {:error, term()}

Deletes a bucket in InfluxDB v2 (backwards compatibility).

@spec delete_database(InfluxElixir.Client.connection(), binary()) ::
  :ok | {:error, term()}

Deletes a database in InfluxDB v3.

@spec delete_token(InfluxElixir.Client.connection(), binary()) ::
  :ok | {:error, term()}

Deletes an API token in InfluxDB v3.

@spec execute_sql(
  InfluxElixir.Client.connection(),
  binary(),
  keyword()
) :: {:ok, map()} | {:error, term()}

Executes a non-SELECT SQL statement (DELETE, INSERT INTO ... SELECT).

@spec flush(atom()) :: :ok | {:error, :no_batch_writer}

Forces an immediate flush of the batch writer for a connection.

Returns :ok on success or {:error, :no_batch_writer} if no batch writer is configured for the given connection.

@spec health(InfluxElixir.Client.connection()) :: {:ok, map()} | {:error, term()}

Checks the health of an InfluxDB instance.

@spec list_buckets(InfluxElixir.Client.connection()) ::
  {:ok, [map()]} | {:error, term()}

Lists all buckets in InfluxDB v2 (backwards compatibility).

@spec list_databases(InfluxElixir.Client.connection()) ::
  {:ok, [map()]} | {:error, term()}

Lists all databases in InfluxDB v3.

@spec point(
  String.t(),
  %{required(String.t()) => InfluxElixir.Write.Point.field_value()},
  keyword()
) ::
  InfluxElixir.Write.Point.t()

Constructs a new Point struct.

Parameters

• measurement - measurement name
• fields - field key-value pairs
• opts - optional :tags and :timestamp

Examples

InfluxElixir.point("cpu", %{"value" => 0.64},
  tags: %{"host" => "server01"}
)

@spec query_flux(InfluxElixir.Client.connection(), binary(), keyword()) ::
  InfluxElixir.Client.query_result()

Executes a Flux query against InfluxDB v2 (backwards compatibility).

@spec query_influxql(
  InfluxElixir.Client.connection(),
  binary(),
  keyword()
) :: InfluxElixir.Client.query_result()

Executes an InfluxQL query against InfluxDB v3.

@spec query_sql(
  InfluxElixir.Client.connection(),
  binary(),
  keyword()
) :: InfluxElixir.Client.query_result()

Executes a SQL query against InfluxDB v3.

Supports transport: :http | :flight option for transport selection.

@spec query_sql_stream(
  InfluxElixir.Client.connection(),
  binary(),
  keyword()
) :: Enumerable.t()

Executes a streaming SQL query, returning a lazy Stream.

Use for large result sets to avoid loading all rows into memory.

@spec remove_connection(atom()) :: :ok | {:error, term()}

Removes a named connection dynamically at runtime.

@spec resolve_connection(atom() | InfluxElixir.Client.connection()) ::
  InfluxElixir.Client.connection()

Resolves a connection reference to a config keyword list.

Accepts either an atom name (looked up via Connection.fetch!/1) or a keyword/map config (returned as-is).

Examples

resolve_connection(:trading)
resolve_connection(host: "localhost", token: "t")

@spec stats(atom()) :: {:ok, map()} | {:error, :no_batch_writer}

Returns batch writer statistics for a connection.

Returns {:ok, stats_map} or {:error, :no_batch_writer} if no batch writer is configured for the given connection.

@spec write(InfluxElixir.Client.connection(), binary(), keyword()) ::
  InfluxElixir.Client.write_result()

Writes points to InfluxDB using the configured client.