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

Creates a named bucket in this local instance.

Creating an already-existing bucket is idempotent.

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

Creates a named database in this local instance.

Always succeeds — creating an already-existing database is idempotent.

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

Creates a synthetic API token and stores it in ETS.

Returns {:ok, %{id: id, token: token_string, description: desc}}.

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

Deletes a bucket from this local instance.

Returns :ok whether or not the bucket exists, matching the idempotent delete semantics of the v2 API.

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

Deletes a database from this local instance.

Returns {:error, %{status: 404, body: "database not found: name"}} if the database does not exist.

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

Deletes a token by its id field. Returns :ok even if the token was not found, matching real InfluxDB delete semantics.

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

Executes a SQL statement and returns a summary map.

Supports DELETE FROM <measurement> and DELETE FROM <measurement> WHERE ... — matching points are removed from ETS and the count is returned in %{"rows_affected" => N}.

On :v3_core profile, DELETE is not supported (matches real InfluxDB v3 Core behavior) and returns {:error, :delete_not_supported}.

On :v3_enterprise profile, DELETE is supported.

Unknown statements return %{"rows_affected" => 0}.

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

Returns a passing health status map with string keys, matching the JSON-decoded shape returned by the HTTP client.

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

Returns all buckets in this local instance as a list of maps with a single :name key.

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

Returns all databases created in this local instance as a list of maps with a single :name key.

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

Executes a Flux query with support for common predicates.

Parses and applies:

• from(bucket: "...") — scopes to a database
• range(start: -1h) — filters by timestamp (supports -Nh, -Nd, -Nm)
• filter(fn: (r) => r._measurement == "...") — filters by measurement
• filter(fn: (r) => r.<key> == "...") — filters by any tag/field equality

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

Executes an InfluxQL query.

Supports InfluxQL-specific commands:

• SHOW DATABASES — returns all databases
• SHOW MEASUREMENTS — returns all measurement names
• SHOW TAG KEYS FROM <measurement> — returns distinct tag keys
• SELECT ... — delegates to the SQL engine

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

Executes a SQL-like query against stored ETS points and returns rows.

Supports:

• SELECT * FROM measurement
• SELECT DISTINCT column FROM measurement
• WHERE key = 'value' / WHERE key > N / WHERE key < N
• ORDER BY time ASC|DESC
• LIMIT N
• $param placeholder substitution via params: %{"$name" => value}

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

Executes a SQL query and returns results as a lazy Stream.

Delegates to query_sql/3 then wraps the list in a stream.

@spec start(keyword()) :: {:ok, conn()}

Starts a new LocalClient instance with isolated ETS storage.

Options

• :database - connection-level default database name. Used when the caller does not pass database: in opts. Pre-created automatically.
• :databases - list of database names to pre-create (default: [])
• :profile - InfluxDB version profile to emulate. Determines which operations are available. Operations outside the profile return {:error, :unsupported_operation}. Valid values:
  • :v3_core (default) — write, SQL, InfluxQL, database CRUD
  • :v3_enterprise — everything in v3_core plus token management
  • :v2 — write, Flux, bucket CRUD

Examples

iex> {:ok, conn} = InfluxElixir.Client.Local.start(databases: ["mydb"])
iex> conn.profile
:v3_core

iex> {:ok, conn} = InfluxElixir.Client.Local.start(profile: :v2)
iex> conn.profile
:v2

iex> {:ok, conn} = InfluxElixir.Client.Local.start(database: "metrics")
iex> conn.database
"metrics"

@spec stop(conn()) :: :ok

Stops a LocalClient instance and cleans up its ETS table.

Safe to call multiple times; a no-op if the table is already deleted.

@spec supports?(conn(), atom()) :: boolean()

Returns true if the given operation is supported by the connection's profile.

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

Parses line protocol binary and stores the resulting points in ETS.

The database is read from opts[:database]. If the database does not exist an {:error, %{status: 404, body: ...}} is returned. If line protocol cannot be parsed an {:error, %{status: 400, body: ...}} is returned.

Payloads beginning with gzip magic bytes are automatically decompressed. Pass precision: :nanosecond | :microsecond | :millisecond | :second to control how numeric timestamps are interpreted (default: :nanosecond).