Packages
snakepit
0.8.6
0.13.0
0.12.0
0.11.1
0.11.0
0.10.1
0.10.0
0.9.1
0.9.0
0.8.9
0.8.8
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.11
0.6.10
0.6.9
0.6.8
0.6.7
0.6.6
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.1
0.5.0
0.4.3
0.4.2
0.4.1
0.4.0
0.3.3
0.3.2
0.3.1
0.3.0
0.2.1
0.2.0
0.1.2
0.1.1
0.1.0
High-performance pooler and session manager for external language integrations. Supports Python, Node.js, Ruby, and more with gRPC streaming, session management, and production-ready process cleanup.
Current section
Files
Jump to
Current section
Files
lib/snakepit/telemetry/control.ex
defmodule Snakepit.Telemetry.Control do
@moduledoc """
Helper functions for creating telemetry control messages.
Control messages flow from Elixir to Python workers over the gRPC
telemetry stream to adjust telemetry behavior at runtime.
"""
alias Snakepit.Bridge.{
TelemetryControl,
TelemetryEventFilter,
TelemetrySamplingUpdate,
TelemetryToggle
}
@doc """
Creates a control message to enable or disable telemetry.
## Examples
iex> Snakepit.Telemetry.Control.toggle(true)
%Snakepit.Bridge.TelemetryControl{
control: {:toggle, %Snakepit.Bridge.TelemetryToggle{enabled: true}}
}
"""
def toggle(enabled) when is_boolean(enabled) do
%TelemetryControl{
control: {:toggle, %TelemetryToggle{enabled: enabled}}
}
end
@doc """
Creates a control message to adjust sampling rate.
The sampling rate must be between 0.0 and 1.0, where:
- 0.0 = no events emitted
- 1.0 = all events emitted
- 0.1 = 10% of events emitted
Event patterns use glob-style matching (e.g., "python.*").
## Examples
iex> Snakepit.Telemetry.Control.sampling(0.5)
%Snakepit.Bridge.TelemetryControl{
control: {:sampling, %Snakepit.Bridge.TelemetrySamplingUpdate{
sampling_rate: 0.5,
event_patterns: []
}}
}
iex> Snakepit.Telemetry.Control.sampling(0.1, ["python.call.*"])
%Snakepit.Bridge.TelemetryControl{
control: {:sampling, %Snakepit.Bridge.TelemetrySamplingUpdate{
sampling_rate: 0.1,
event_patterns: ["python.call.*"]
}}
}
"""
def sampling(rate, patterns \\ [])
when is_number(rate) and rate >= 0.0 and rate <= 1.0 and is_list(patterns) do
%TelemetryControl{
control:
{:sampling,
%TelemetrySamplingUpdate{
sampling_rate: rate,
event_patterns: Enum.map(patterns, &to_string/1)
}}
}
end
@doc """
Creates a control message to filter events.
Allows explicit whitelisting or blacklisting of events.
## Examples
iex> Snakepit.Telemetry.Control.filter(allow: ["python.call.start"])
%Snakepit.Bridge.TelemetryControl{
control: {:filter, %Snakepit.Bridge.TelemetryEventFilter{
allow: ["python.call.start"],
deny: []
}}
}
iex> Snakepit.Telemetry.Control.filter(deny: ["python.memory.sampled"])
%Snakepit.Bridge.TelemetryControl{
control: {:filter, %Snakepit.Bridge.TelemetryEventFilter{
allow: [],
deny: ["python.memory.sampled"]
}}
}
"""
def filter(opts \\ []) do
allow = Keyword.get(opts, :allow, []) |> Enum.map(&to_string/1)
deny = Keyword.get(opts, :deny, []) |> Enum.map(&to_string/1)
%TelemetryControl{
control:
{:filter,
%TelemetryEventFilter{
allow: allow,
deny: deny
}}
}
end
end