antikythera v0.3.0 AntikytheraCore.Metrics.Buffer View Source

A bin-like data structure to hold per-minute, per-epool metrics data.

%{
  {time_minute, epool_id} => %{
    {metrics_type, strategy} => data_in_processing,
    {metrics_type, strategy} => data_in_processing,
    ...
  },
  ...
}

Link to this section Summary

Types

epool_id()

metrics_data_map()

metrics_type()

metrics_unit()

metrics_value()

minute()

t()

Functions

add(buffer, now, list, epool_id)

new()

partition_ongoing_and_past(buffer, now)

Link to this section Types

epool_id()

epool_id() ::
  Antikythera.ExecutorPool.Id.nopool_t() | Antikythera.ExecutorPool.Id.t()

metrics_data_map()

metrics_data_map() :: %{required(metrics_type()) => metrics_value()}

metrics_type()

metrics_type() :: {String.t(), AntikytheraCore.Metrics.AggregateStrategy.t()}

metrics_unit()

metrics_unit() :: {minute(), epool_id()}

metrics_value()

metrics_value() :: AntikytheraCore.Metrics.AggregateStrategy.data_t()

minute()

minute() :: Antikythera.Time.t()

t()

t() :: %{required(metrics_unit()) => metrics_data_map()}

Link to this section Functions

add(buffer, now, list, epool_id)

add(
  t(),
  Antikythera.Time.t(),
  [{String.t(), AntikytheraCore.Metrics.AggregateStrategy.t(), number()}],
  epool_id()
) :: t()

new()

new() :: t()

partition_ongoing_and_past(buffer, now)

partition_ongoing_and_past(t(), Antikythera.Time.t()) ::
  {t(), [{metrics_unit(), metrics_data_map()}]}