Packages
new_relic_agent
1.16.1
1.40.3
1.40.2
1.40.1
1.40.0
1.39.0
1.38.0
1.37.0
1.36.0
1.35.0
1.34.0
1.33.0
1.32.0
1.31.1
1.31.0
1.30.0
1.29.0
1.28.0
1.27.8
1.27.7
1.27.6
1.27.5
1.27.4
1.27.3
1.27.2
1.27.1
1.27.0
1.26.0
1.25.3
1.25.2
1.25.1
1.25.0
1.24.5
1.24.4
1.24.3
1.24.2
1.24.1
1.24.0
1.24.0-rc.10
1.24.0-rc.9
1.24.0-rc.8
1.24.0-rc.7
1.23.6
1.23.5
1.23.4
1.23.3
1.23.2
1.23.1
1.23.0
1.23.0-rc.6
1.23.0-rc.5
1.23.0-rc.4
1.23.0-rc.3
1.23.0-rc.2
1.23.0-rc.1
1.22.6
1.22.5
1.22.4
1.22.3
1.22.2
1.22.1
1.22.0
1.21.2
1.21.1
1.21.0
1.21.0-rc.3
1.21.0-rc.1
1.20.0
1.20.0-rc.1
1.19.7
1.19.6
1.19.5
1.19.4
1.19.3
1.19.2
1.19.1
1.19.0
1.18.5
1.18.4
1.18.3
1.18.2
1.18.1
1.18.0
1.18.0-rc.5
1.18.0-rc.4
1.18.0-rc.2
1.18.0-rc.1
1.17.1
1.17.0
1.17.0-rc.4
1.17.0-rc.3
1.17.0-rc.2
1.17.0-rc.1
1.17.0-rc.0
1.16.7
1.16.6
1.16.5
1.16.4
1.16.3
1.16.2
1.16.1
1.16.0
1.16.0-rc.2
1.16.0-rc.1
1.16.0-rc.0
1.15.0
1.15.0-rc.3
1.15.0-rc.2
1.15.0-rc.1
1.14.0
1.13.1
1.13.0
1.12.0
1.11.0
1.10.2
1.10.1
1.10.0
1.9.12
1.9.11
1.9.10
1.9.9
1.9.8
1.9.7
1.9.6
1.9.5
1.9.4
1.9.3
1.9.2
1.9.1
1.9.0
1.8.0
1.7.0
1.6.2
1.6.1
1.6.0
1.5.0
1.4.0
1.3.2
1.3.1
1.3.0
1.2.1
1.2.0
1.1.0
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
New Relic's Open-Source Elixir Agent
Current section
Files
Jump to
Current section
Files
lib/new_relic/telemetry/ecto.ex
defmodule NewRelic.Telemetry.Ecto do
use GenServer
@moduledoc """
`NewRelic.Telemetry.Ecto` provides `Ecto` instrumentation via `telemetry`.
Repos are auto-discovered and instrumented. We automatically gather:
* Datastore metrics
* Transaction Trace segments
* Transaction datastore attributes
* Distributed Trace span events
You can opt-out of this instrumentation as a whole and specifically of
SQL query collection via configuration. See `NewRelic.Config` for details.
"""
def start_link(otp_app) do
enabled = NewRelic.Config.feature?(:ecto_instrumentation)
ecto_repos = Application.get_env(otp_app, :ecto_repos)
config = extract_config(otp_app, ecto_repos)
GenServer.start_link(__MODULE__, config: config, enabled: enabled)
end
def init(config: _, enabled: false), do: :ignore
def init(config: config, enabled: true) do
log(config)
:telemetry.attach_many(
config.handler_id,
config.events,
&NewRelic.Telemetry.Ecto.Handler.handle_event/4,
config
)
Process.flag(:trap_exit, true)
{:ok, config}
end
def terminate(_reason, %{handler_id: handler_id}) do
:telemetry.detach(handler_id)
end
defp extract_config(otp_app, ecto_repos) do
%{
otp_app: otp_app,
events: extract_events(otp_app, ecto_repos),
repo_configs: extract_repo_configs(otp_app, ecto_repos),
collect_sql?: NewRelic.Config.feature?(:sql_collection),
handler_id: {:new_relic_ecto, otp_app}
}
end
defp extract_events(otp_app, ecto_repos) do
Enum.map(ecto_repos, fn repo ->
ecto_telemetry_prefix(otp_app, repo) ++ [:query]
end)
end
defp extract_repo_configs(otp_app, ecto_repos) do
Enum.into(ecto_repos, %{}, fn repo ->
{repo, extract_repo_config(otp_app, repo)}
end)
end
defp extract_repo_config(otp_app, repo) do
Application.get_env(otp_app, repo)
|> Map.new()
|> case do
%{url: url} ->
uri = URI.parse(url)
%{
hostname: uri.host,
port: uri.port,
database: uri.path |> String.trim_leading("/")
}
config ->
config
end
end
defp ecto_telemetry_prefix(otp_app, repo) do
Application.get_env(otp_app, repo)
|> Keyword.get_lazy(:telemetry_prefix, fn ->
repo
|> Module.split()
|> Enum.map(&(&1 |> Macro.underscore() |> String.to_atom()))
end)
end
defp log(%{repo_configs: repo_configs}) do
for {repo, _config} <- repo_configs do
NewRelic.log(:info, "Detected Ecto Repo `#{inspect(repo)}`")
end
end
end