Time-series helpers for ArcadeDB TimeSeries types and endpoints.
Arex.TimeSeries covers three layers of the ArcadeDB time-series surface:
- SQL-backed DDL and analytical queries
- dedicated JSON and line-protocol HTTP endpoints
- PromQL, Grafana, and Prometheus-compatible HTTP endpoints
The helpers return the same {:ok, value} and {:error, error_map} shapes as
the rest of Arex. When you need a TimeSeries capability that is not wrapped
here yet, use Arex.Query.sql/3, Arex.Command.sql/3, or Arex.Http.request/4.
Arex treats time-series data as boundary-aware when you use the structured helpers:
- helper-managed type creation adds
tenantandscopetags when needed - helper-managed writes stamp active boundaries into rows or line protocol
- wrapped SQL and latest-point helpers apply those boundary tags on read
Raw SQL, raw PromQL, and raw payload helpers remain available when callers need full control over the underlying ArcadeDB surface.
Summary
Functions
Adds one or more downsampling policies to a TimeSeries type.
Lists continuous aggregates from schema:continuousAggregates.
Creates a continuous aggregate.
Creates a TimeSeries type with the given timestamp, tags, and fields definition.
Drops a continuous aggregate.
Drops all downsampling policies from a TimeSeries type.
Drops a TimeSeries type.
Checks the Grafana datasource health endpoint for ArcadeDB TimeSeries.
Fetches Grafana metadata for ArcadeDB TimeSeries types.
Executes a Grafana DataFrame-style query.
Inserts a single sample map into a TimeSeries type using SQL content syntax.
Inserts multiple sample maps into a TimeSeries type in one SQLScript transaction.
Fetches the latest point for a TimeSeries type.
Lists available values for a PromQL label.
Lists available PromQL label names.
Sends a raw Prometheus remote-read payload.
Sends a raw Prometheus remote-write payload.
Finds series matching one or more PromQL selectors.
Executes a PromQL instant query.
Executes a PromQL range query.
Evaluates a PromQL expression through SQL using promql().
Executes a TimeSeries JSON query against /api/v1/ts/:db/query.
Executes a SQL query against TimeSeries data.
Refreshes a continuous aggregate.
Writes InfluxDB line protocol samples to /api/v1/ts/:db/write.
Functions
Adds one or more downsampling policies to a TimeSeries type.
Lists continuous aggregates from schema:continuousAggregates.
Creates a continuous aggregate.
Creates a TimeSeries type with the given timestamp, tags, and fields definition.
Drops a continuous aggregate.
Drops all downsampling policies from a TimeSeries type.
Drops a TimeSeries type.
Checks the Grafana datasource health endpoint for ArcadeDB TimeSeries.
Fetches Grafana metadata for ArcadeDB TimeSeries types.
Executes a Grafana DataFrame-style query.
Inserts a single sample map into a TimeSeries type using SQL content syntax.
Inserts multiple sample maps into a TimeSeries type in one SQLScript transaction.
Fetches the latest point for a TimeSeries type.
Lists available values for a PromQL label.
Lists available PromQL label names.
Sends a raw Prometheus remote-read payload.
Sends a raw Prometheus remote-write payload.
Finds series matching one or more PromQL selectors.
Executes a PromQL instant query.
Executes a PromQL range query.
Evaluates a PromQL expression through SQL using promql().
Executes a TimeSeries JSON query against /api/v1/ts/:db/query.
Executes a SQL query against TimeSeries data.
Refreshes a continuous aggregate.
Writes InfluxDB line protocol samples to /api/v1/ts/:db/write.