Packages

scout_apm

1.0.3
2.0.0 2.0.0-rc.1 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.4.15 0.4.14 0.4.13 0.4.11 0.4.10 0.4.9 0.4.8 0.4.7 0.4.6 0.4.5 0.4.4 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.12 0.2.11 0.2.10 0.2.9 retired 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.0

ScoutAPM agent for Phoenix & Elixir projects. For more information, visit https://www.scoutapm.com/agents/elixir-phoenix-monitoring.

HexDocs

Current section

Files

Jump to
Readme
43 Versions
5 Dependencies
Dependants
Files
Activity
scout_apm lib scout_apm instruments ecto_telemetry.ex
Raw

lib/scout_apm/instruments/ecto_telemetry.ex 

if Code.ensure_loaded?(Telemetry) || Code.ensure_loaded?(:telemetry) do

  defmodule ScoutApm.Instruments.EctoTelemetry do

    @doc """

    Attaches an event handler for Ecto queries.



    Takes a fully namespaced Ecto.Repo module as the only argument. Example:



        ScoutApm.Instruments.EctoTelemetry.attach(MyApp.Repo)

    """

    def attach(repo_module) do

      query_event =

        repo_module

        |> Module.split()

        |> Enum.map(&(&1 |> Macro.underscore() |> String.to_atom()))

        |> Kernel.++([:query])



      :telemetry.attach(

        "ScoutApm Ecto Instrument Hook for " <> Macro.underscore(repo_module),

        query_event,

        &ScoutApm.Instruments.EctoTelemetry.handle_event/4,

        nil

      )

    end



    def handle_event(query_event, value, metadata, _config) when is_list(query_event) do

      if :query == List.last(query_event) do

        ScoutApm.Instruments.EctoLogger.record(value, metadata)

      end

    end

  end

end