Packages

spawn

1.3.2
2.0.0-RC9 2.0.0-RC8 2.0.0-RC7 2.0.0-RC6 2.0.0-RC5 2.0.0-RC4 2.0.0-RC3 2.0.0-RC2 2.0.0-RC14 2.0.0-RC13 2.0.0-RC12 2.0.0-RC11 2.0.0-RC10 2.0.0-RC1 1.4.3 1.4.2 1.4.1 1.4.0 1.3.3 1.3.2 1.3.1 1.3.0 1.2.1 1.2.0 1.1.1 1.1.0 1.0.1 1.0.0 1.0.0-rc3 1.0.0-rc16 1.0.0-rc1 1.0.0-rc.38 1.0.0-rc.37 1.0.0-rc.36 1.0.0-rc.35 1.0.0-rc.34 1.0.0-rc.33 1.0.0-rc.32 1.0.0-rc.31 1.0.0-rc.30 1.0.0-rc.29 1.0.0-rc.28 1.0.0-rc.27 1.0.0-rc.26 1.0.0-rc.25 1.0.0-rc.24 1.0.0-rc.23 1.0.0-rc.22 1.0.0-rc.21 1.0.0-rc.20 1.0.0-rc.19 1.0.0-rc.18 1.0.0-rc.17 1.0.0-rc.2 0.6.3 0.6.2 0.6.1 0.6.0 0.5.5 0.5.4 0.5.3 0.5.1 0.5.0 0.5.0-rc.13 0.5.0-rc.12 0.5.0-rc.11 0.5.0-rc.10 0.5.0-rc.9 0.5.0-rc.8 0.5.0-rc.7 0.5.0-rc.6 0.5.0-rc.5 0.5.0-rc.3 0.5.0-alpha.13 0.5.0-alpha.12 0.5.0-alpha.11 0.5.0-alpha.10 0.5.0-alpha.9 0.5.0-alpha.8 0.5.0-alpha.7 0.5.0-alpha.6 0.5.0-alpha.5 0.5.0-alpha.4 0.5.0-alpha.3 0.5.0-alpha.2 0.5.0-alpha.1 0.1.0

Spawn is the core lib for Spawn Actors System

HexDocs

Current section

Files

Jump to
Readme
87 Versions
34 Dependencies
Dependants
Files
Activity
spawn lib sidecar metrics_supervisor.ex
Raw

lib/sidecar/metrics_supervisor.ex 

defmodule Sidecar.MetricsSupervisor do

  @moduledoc false

  use Supervisor

  import Telemetry.Metrics

  import Spawn.Utils.Common, only: [supervisor_process_logger: 1]



  alias Actors.Config.PersistentTermConfig, as: Config



  def start_link(opts) do

    Supervisor.start_link(__MODULE__, opts, name: __MODULE__)

  end



  def init(opts) do

    children =

      if Config.get(:proxy_disable_metrics),

        do: [supervisor_process_logger(__MODULE__)],

        else: [supervisor_process_logger(__MODULE__)] ++ get_metrics_supervisor_tree(opts)



    Supervisor.init(children, strategy: :one_for_one)

  end



  defp get_metrics_supervisor_tree(opts) do

    if Config.get(:proxy_console_metrics) do

      [

        {:telemetry_poller, measurements: periodic_measurements(opts)},

        {TelemetryMetricsPrometheus.Core, name: :spawm_metrics, metrics: metrics()},

        {Telemetry.Metrics.ConsoleReporter, metrics: metrics()}

      ]

    else

      [

        {:telemetry_poller, measurements: periodic_measurements(opts)},

        {TelemetryMetricsPrometheus.Core, name: :spawm_metrics, metrics: metrics()}

      ]

    end

  end



  defp metrics do

    [

      # VM Metrics

      last_value("vm.system_info.process_count"),

      last_value("vm.system_info.schedulers"),

      last_value("vm.system_info.schedulers_online"),

      last_value("vm.system_info.dirty_cpu_schedulers"),

      last_value("vm.system_info.dirty_cpu_schedulers_online"),

      last_value("vm.system_info.thread_pool_size"),

      last_value("vm.system_info.dist_buf_busy_limit", unit: :byte),

      last_value("vm.memory.total", unit: :byte),

      last_value("vm.total_run_queue_lengths.total"),

      last_value("vm.total_run_queue_lengths.cpu"),

      last_value("vm.total_run_queue_lengths.io"),



      # Actor Metrics

      last_value("spawn.actor.memory", unit: :byte),

      last_value("spawn.actor.message_queue_len"),

      last_value("spawn.actor.inflight_messages.messages"),

      counter("spawn.invoke.stop.duration"),

      summary("spawn.invoke.stop.duration", unit: {:native, :millisecond})

    ]

  end



  defp periodic_measurements(opts) do

    [

      {:process_info,

       event: [:spawn, :actor], name: Actors.Actor.Entity, keys: [:message_queue_len, :memory]},

      {Sidecar.Measurements, :stats, [opts]}

    ]

  end

end