Parrhesia.ConnectionStats (parrhesia v0.12.0)

Per-listener connection and subscription counters.

Tracks active connection and subscription counts per listener and emits [:parrhesia, :listener, :population] telemetry events on each change.

Summary

Types

state()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

connection_close(listener_id)

connection_open(listener_id)

start_link(opts \\ [])

subscriptions_change(listener_id, delta)

Types

state()

@type state() :: %Parrhesia.ConnectionStats{
  connections: %{required(atom() | String.t()) => non_neg_integer()},
  subscriptions: %{required(atom() | String.t()) => non_neg_integer()}
}

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

connection_close(listener_id)

@spec connection_close(atom() | String.t()) :: :ok

connection_open(listener_id)

@spec connection_open(atom() | String.t()) :: :ok

start_link(opts \\ [])

@spec start_link(keyword()) :: GenServer.on_start()

subscriptions_change(listener_id, delta)

@spec subscriptions_change(atom() | String.t(), integer()) :: :ok