Packages

spawn

0.6.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
28 Dependencies
Dependants
Files
Activity
spawn lib sidecar measurements.ex
Raw

lib/sidecar/measurements.ex 

defmodule Sidecar.Measurements do

  @moduledoc false



  def stats(config) do

    otp_release = :erlang.system_info(:otp_release)

    multi_scheduling = :erlang.system_info(:multi_scheduling)

    threads = :erlang.system_info(:threads)

    smp_support = :erlang.system_info(:smp_support)



    dirty_cpu_schedulers = :erlang.system_info(:dirty_cpu_schedulers)

    dirty_cpu_schedulers_online = :erlang.system_info(:dirty_cpu_schedulers_online)

    dist_buf_busy_limit = :erlang.system_info(:dist_buf_busy_limit)

    process_count = :erlang.system_info(:process_count)

    schedulers = :erlang.system_info(:schedulers)

    schedulers_online = :erlang.system_info(:schedulers_online)

    thread_pool_size = :erlang.system_info(:thread_pool_size)



    :telemetry.execute(

      [:vm, :system_info],

      %{

        dirty_cpu_schedulers: dirty_cpu_schedulers,

        dirty_cpu_schedulers_online: dirty_cpu_schedulers_online,

        dist_buf_busy_limit: dist_buf_busy_limit,

        process_count: process_count,

        schedulers: schedulers,

        schedulers_online: schedulers_online,

        thread_pool_size: thread_pool_size

      },

      %{

        host_ip: config.node_host_interface,

        proxy_ip: config.proxy_host_interface,

        otp_release: "#{otp_release}",

        smp_support: smp_support,

        multi_scheduling: multi_scheduling,

        threads: threads

      }

    )

  end



  def dispatch_invoke_duration(system, actor_name, action, duration) do

    :telemetry.execute(

      [:spawn, :invoke, :stop],

      %{duration: duration},

      %{system: system, name: actor_name, action: action}

    )

  end



  def dispatch_actor_inflights(system, actor_name, value) do

    :telemetry.execute([:spawn, :actor, :inflight_messages], %{messages: value}, %{

      system: system,

      name: actor_name

    })

  end

end