antikythera

v0.3.0

antikythera v0.3.0 AntikytheraCore.MetricsUploader View Source

A GenServer which buffers metrics data and periodically flushes the aggregated results to stable storage.

Link to this section Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(list)
submit(worker_name, data_list, epool_id)
submit_custom_metrics(worker_name, data_list0, context)
submit_with_time(worker_name, now, data_list, epool_id)

Link to this section Functions

Link to this function

child_spec(init_arg)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

start_link(list)

View Source
Link to this function

submit(worker_name, data_list, epool_id)

View Source 
submit(
  GenServer.server(),
  Antikythera.Metrics.DataList.t(),
  AntikytheraCore.Metrics.Buffer.epool_id()
) :: :ok
Link to this function

submit_custom_metrics(worker_name, data_list0, context)

View Source 
submit_custom_metrics(
  GenServer.server(),
  Antikythera.Metrics.DataList.t(),
  nil | Antikythera.Context.t()
) :: :ok
Link to this function

submit_with_time(worker_name, now, data_list, epool_id)

View Source 
submit_with_time(
  GenServer.server(),
  Antikythera.Time.t(),
  Antikythera.Metrics.DataList.t(),
  AntikytheraCore.Metrics.Buffer.epool_id()
) :: :ok