Packages

timeless_metrics

6.2.1
6.2.2 6.2.1 6.2.0 6.1.3 6.1.2 6.1.1 6.1.0 6.0.22 6.0.21 6.0.20 6.0.19 6.0.18 6.0.17 6.0.16 6.0.15 6.0.14 6.0.13 6.0.12 6.0.11 6.0.10 6.0.9 6.0.8 6.0.6 6.0.5 6.0.4 6.0.3

Embedded time series database for Elixir with a Rust-native hot path.

HexDocs

Current section

Files

Jump to
Readme
26 Versions
9 Dependencies
Dependants
Files
Activity
timeless_metrics lib timeless_metrics rust_engine nif.ex
Raw

lib/timeless_metrics/rust_engine/nif.ex 

defmodule TimelessMetrics.RustEngine.Nif do

  @moduledoc false

  use Rustler, otp_app: :timeless_metrics, crate: "tms_engine", skip_compilation?: true



  def engine_new(

        _data_dir,

        _flush_threshold,

        _min_flush_size,

        _compression_level,

        _memory_budget_mb,

        _defer_compression

      ),

      do: :erlang.nif_error(:nif_not_loaded)



  def engine_compact(_engine, _cutoff_ts), do: :erlang.nif_error(:nif_not_loaded)



  def engine_write_batch_labeled(_engine, _entries), do: :erlang.nif_error(:nif_not_loaded)

  def engine_write_batch_raw(_engine, _binary), do: :erlang.nif_error(:nif_not_loaded)

  def engine_resolve_series(_engine, _metric, _labels), do: :erlang.nif_error(:nif_not_loaded)

  def engine_resolve_series_batch(_engine, _entries), do: :erlang.nif_error(:nif_not_loaded)

  def engine_flush_pending(_engine), do: :erlang.nif_error(:nif_not_loaded)

  def engine_flush_cold(_engine, _max_idle_secs), do: :erlang.nif_error(:nif_not_loaded)

  def engine_flush_by_memory(_engine), do: :erlang.nif_error(:nif_not_loaded)

  def engine_flush(_engine), do: :erlang.nif_error(:nif_not_loaded)

  def engine_delete_before(_engine, _before_ts), do: :erlang.nif_error(:nif_not_loaded)

  def engine_shutdown(_engine), do: :erlang.nif_error(:nif_not_loaded)



  def engine_query_range(_engine, _metric, _labels, _t_start, _t_end),

    do: :erlang.nif_error(:nif_not_loaded)



  def engine_query_aggregate(_engine, _metric, _labels, _t_start, _t_end, _agg),

    do: :erlang.nif_error(:nif_not_loaded)



  def engine_list_metrics(_engine), do: :erlang.nif_error(:nif_not_loaded)

  def engine_list_labels(_engine), do: :erlang.nif_error(:nif_not_loaded)

  def engine_label_values(_engine, _metric, _label_key), do: :erlang.nif_error(:nif_not_loaded)

  def engine_list_series(_engine, _metric), do: :erlang.nif_error(:nif_not_loaded)

  def engine_info(_engine), do: :erlang.nif_error(:nif_not_loaded)



  # Prometheus text parser (production; wrapped by TimelessMetrics.PrometheusNif)

  def parse_prometheus(_body), do: :erlang.nif_error(:nif_not_loaded)

  # Fused parse -> resolve -> write ingest; returns {:ok, {count, errors}}

  def engine_ingest_prometheus(_engine, _body, _default_ts),

    do: :erlang.nif_error(:nif_not_loaded)



  # Bench-only: parse without term materialization (bench/ingest_segments_bench.exs)

  def parse_prometheus_count(_body), do: :erlang.nif_error(:nif_not_loaded)

end