View Source AntikytheraCore.MetricsUploader (antikythera v0.5.1)

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

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)

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 
@spec 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 
@spec 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 
@spec submit_with_time(
  GenServer.server(),
  Antikythera.Time.t(),
  Antikythera.Metrics.DataList.t(),
  AntikytheraCore.Metrics.Buffer.epool_id()
) :: :ok