Modules
Elixir client library for InfluxDB v3 with v2 compatibility.
v2 bucket CRUD operations for backwards compatibility.
v3 database CRUD operations via /api/v3/configure/database.
Health and ping checks for InfluxDB instances.
v3 token management via /api/v3/configure/token.
OTP Application entry point for InfluxElixir.
Behaviour defining the InfluxDB client contract.
Production InfluxDB client implementation using Finch.
In-memory InfluxDB client for fast, isolated testing.
Connection configuration validation and defaults.
Named connection manager for InfluxDB instances.
Per-connection supervisor using :rest_for_one strategy.
Arrow Flight gRPC client for high-throughput query transport.
Minimal FlatBuffer binary reader for Arrow IPC metadata.
Protobuf message definitions for the Apache Arrow Flight protocol.
A chunk of Arrow IPC data streamed from a DoGet call.
Describes how to locate or identify a Flight (a named dataset or query).
A Ticket paired with a list of Locations that can serve the data.
Metadata returned by GetFlightInfo, describing a result set.
gRPC service definition for the Arrow Flight protocol.
Generated gRPC client stub for FlightService.
Initial client message in the Handshake RPC.
Server response in the Handshake RPC.
A URI identifying where a Flight service is available.
An opaque bytes token identifying a result set.
Arrow IPC record batch decoder for Arrow Flight query results.
v2 Flux query executor for backwards compatibility.
v3 InfluxQL query executor for legacy query compatibility.
Parses InfluxDB query responses in JSONL, CSV, JSON, and Parquet formats with type coercion.
v3 SQL query builder and executor.
Streaming JSONL query results as a lazy Elixir Stream.
Top-level supervisor for InfluxElixir.
Telemetry event emission for write and query operations.
GenServer-based batch writer with configurable flush intervals, batch sizes, retry with exponential backoff, and backpressure.
Encodes Point structs into InfluxDB line protocol format.
Point struct representing a single InfluxDB data point.
Direct single-request write to InfluxDB.