Setup opentelemetry_exporter

Author: sl0thentr0py

lib/sentry/application.ex

@@ -59,5 +59,9 @@ defmodule Sentry.Application do
     if config[:quantum][:cron][:enabled] do
       Sentry.Integrations.Quantum.Cron.attach_telemetry_handler()
     end
+
+    if config[:opentelemetry] do
+      Sentry.Integrations.Opentelemetry.setup()
+    end
   end
 end

lib/sentry/config.ex

@@ -62,6 +62,14 @@ defmodule Sentry.Config do
           ]
         ]
       ]
+    ],
+    opentelemetry: [
+      type: :boolean,
+      doc: """
+      A boolean switch that sets up [OpenTelemetry](https://opentelemetry.io/docs/languages/erlang/)
+      automatically to instrument your application and export the spans to Sentry.
+      *Available since vTODO*.
+      """
     ]
   ]
 
@@ -464,37 +472,43 @@ defmodule Sentry.Config do
   @spec dsn() :: nil | {String.t(), String.t(), String.t()}
   def dsn, do: get(:dsn)
 
-  @spec envelope_endpoint() :: String.t()
+  @spec envelope_endpoint() :: nil | String.t()
   def envelope_endpoint do
-    {base_uri, _, _} = dsn()
-    base_uri <> "envelope/"
+    case dsn() do
+      {base_uri, _, _}  -> base_uri <> "envelope/"
+      _ -> nil
+    end
   end
 
-  @spec spans_endpoint() :: String.t()
+  @spec spans_endpoint() :: nil | String.t()
   def spans_endpoint do
-    {base_uri, _, _} = dsn()
-    base_uri <> "spans/"
+    case dsn() do
+      {base_uri, _, _}  -> base_uri <> "spans/"
+      _ -> nil
+    end
   end
 
-  @spec auth_headers() :: [{String.t(), String.t()}]
+  @spec auth_headers() :: nil | [{String.t(), String.t()}]
   def auth_headers do
-    {_, public_key, secret_key} = dsn()
-
-    auth_query =
-      [
-        sentry_version: @sentry_version,
-        sentry_client: @sentry_client,
-        sentry_timestamp: System.system_time(:second),
-        sentry_key: public_key,
-        sentry_secret: secret_key
-      ]
-      |> Enum.reject(fn {_, value} -> is_nil(value) end)
-      |> Enum.map_join(", ", fn {name, value} -> "#{name}=#{value}" end)
+    case dsn() do
+      {_, public_key, secret_key} ->
+        auth_query =
+          [
+            sentry_version: @sentry_version,
+            sentry_client: @sentry_client,
+            sentry_timestamp: System.system_time(:second),
+            sentry_key: public_key,
+            sentry_secret: secret_key
+          ]
+          |> Enum.reject(fn {_, value} -> is_nil(value) end)
+          |> Enum.map_join(", ", fn {name, value} -> "#{name}=#{value}" end)
 
-    [
-      {"User-Agent", @sentry_client},
-      {"X-Sentry-Auth", "Sentry " <> auth_query}
-    ]
+        [
+          {"User-Agent", @sentry_client},
+          {"X-Sentry-Auth", "Sentry " <> auth_query}
+        ]
+      _ -> nil
+    end
   end
 
   # TODO: remove me on v11.0.0, :included_environments has been deprecated

lib/sentry/integrations/opentelemetry.ex

@@ -0,0 +1,16 @@
+defmodule Sentry.Integrations.Opentelemetry do
+  @moduledoc false
+
+  alias Sentry.Config
+
+  def setup do
+    if Config.dsn() do
+      Application.put_env(:opentelemetry, :traces_exporter, :otlp)
+      Application.put_env(:opentelemetry_exporter, :otlp_protocol, :http_protobuf)
+      Application.put_env(:opentelemetry_exporter, :otlp_traces_endpoint, Config.spans_endpoint())
+      Application.put_env(:opentelemetry_exporter, :otlp_headers, Config.auth_headers())
+    end
+
+    :ok
+  end
+end

lib/sentry/transport.ex

@@ -20,8 +20,7 @@ defmodule Sentry.Transport do
       when is_atom(client) and is_list(retries) do
     case Envelope.to_binary(envelope) do
       {:ok, body} ->
-        {endpoint, headers} = {Config.envelope_endpoint(), Config.auth_headers()}
-        post_envelope_with_retries(client, endpoint, headers, body, retries)
+        post_envelope_with_retries(client, Config.envelope_endpoint(), Config.auth_headers(), body, retries)
 
       {:error, reason} ->
         {:error, {:invalid_json, reason}}