From a15f52c423807faa78bda97fe752690e52c4d773 Mon Sep 17 00:00:00 2001
From: Nick Krichevsky <nicholas.krichevsky@discordapp.com>
Date: Thu, 12 Mar 2026 03:04:04 +0000
Subject: [PATCH 1/2] Use Statix event sending

---
 lib/instruments.ex           | 30 +-----------------------------
 lib/stats_reporter.ex        |  7 +++++++
 lib/stats_reporter/logger.ex |  5 +++++
 lib/stats_reporter/null.ex   |  3 +++
 4 files changed, 16 insertions(+), 29 deletions(-)

diff --git a/lib/instruments.ex b/lib/instruments.ex
index 953d13a..5f27282 100644
--- a/lib/instruments.ex
+++ b/lib/instruments.ex
@@ -175,35 +175,7 @@ defmodule Instruments do
     title_iodata = MacroHelpers.to_iolist(title_ast, __CALLER__)
 
     quote do
-      title = unquote(title_iodata)
-
-      header = [
-        "_e{",
-        Integer.to_charlist(IO.iodata_length(title)),
-        ",",
-        Integer.to_charlist(IO.iodata_length(unquote(text))),
-        "}:",
-        title,
-        "|",
-        unquote(text)
-      ]
-
-      message =
-        case Keyword.get(unquote(opts), :tags) do
-          nil ->
-            header
-
-          tag_list ->
-            [header, "|#", Enum.intersperse(tag_list, ",")]
-        end
-
-      # Statix registers a port to the name of the metrics module.
-      # and this code assumes that the metrics module is bound to
-      # a port, and sends directly to it. If we move off of Statix,
-      # this will have to be changed.
-      unquote(@metrics_module)
-      |> Process.whereis()
-      |> :gen_udp.send('localhost', Instruments.statsd_port(), message)
+      unquote(@metrics_module).send_event(unquote(title_iodata), unquote(text), unquote(opts))
     end
   end
 
diff --git a/lib/stats_reporter.ex b/lib/stats_reporter.ex
index 6b18029..e1c625f 100644
--- a/lib/stats_reporter.ex
+++ b/lib/stats_reporter.ex
@@ -52,4 +52,11 @@ defmodule Instruments.StatsReporter do
   Write the value into the set defined by `key`
   """
   @callback set(key, integer, keyword) :: stats_return
+
+  @doc """
+  Send a DataDog event with the given title and text
+  """
+  @callback send_event(title :: iodata, text :: iodata, keyword) :: stats_return
+
+  @optional_callbacks [send_event: 3]
 end
diff --git a/lib/stats_reporter/logger.ex b/lib/stats_reporter/logger.ex
index ec99c78..129f273 100644
--- a/lib/stats_reporter/logger.ex
+++ b/lib/stats_reporter/logger.ex
@@ -45,4 +45,9 @@ defmodule Instruments.StatsReporter.Logger do
   def set(key, value, _options \\ []) do
     Logger.info("setting #{key} to #{value}")
   end
+
+  @doc false
+  def send_event(title, text, _options \\ []) do
+    Logger.info("event #{title}: #{text}")
+  end
 end
diff --git a/lib/stats_reporter/null.ex b/lib/stats_reporter/null.ex
index c26fe42..cc20b26 100644
--- a/lib/stats_reporter/null.ex
+++ b/lib/stats_reporter/null.ex
@@ -28,4 +28,7 @@ defmodule Instruments.StatsReporter.Null do
 
   @doc false
   def set(_key, _value, _options \\ []), do: :ok
+
+  @doc false
+  def send_event(_title, _text, _options \\ []), do: :ok
 end

From a9be1c87fc86951d6b83095e42c00598f401cf60 Mon Sep 17 00:00:00 2001
From: Nick Krichevsky <nicholas.krichevsky@discordapp.com>
Date: Thu, 12 Mar 2026 12:56:47 +0000
Subject: [PATCH 2/2] Update Statix

---
 mix.exs  | 2 +-
 mix.lock | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/mix.exs b/mix.exs
index d7a6ffb..f86fa30 100644
--- a/mix.exs
+++ b/mix.exs
@@ -51,7 +51,7 @@ defmodule Instruments.Mixfile do
       {:benchee, "~> 1.4", only: :dev},
       {:ex_doc, "~> 0.28", only: :dev, runtime: false},
       {:recon, "~> 2.5.2"},
-      {:statix, "~> 1.7.0", hex: :discord_statix},
+      {:statix, "~> 1.8.0", hex: :discord_statix},
       {:dialyxir, "~> 1.0", only: :dev, runtime: false}
     ]
   end
diff --git a/mix.lock b/mix.lock
index ae77b56..3de1941 100644
--- a/mix.lock
+++ b/mix.lock
@@ -12,5 +12,5 @@
   "nimble_parsec": {:hex, :nimble_parsec, "1.2.3", "244836e6e3f1200c7f30cb56733fd808744eca61fd182f731eac4af635cc6d0b", [:mix], [], "hexpm", "c8d789e39b9131acf7b99291e93dae60ab48ef14a7ee9d58c6964f59efb570b0"},
   "recon": {:hex, :recon, "2.5.2", "cba53fa8db83ad968c9a652e09c3ed7ddcc4da434f27c3eaa9ca47ffb2b1ff03", [:mix, :rebar3], [], "hexpm", "2c7523c8dee91dff41f6b3d63cba2bd49eb6d2fe5bf1eec0df7f87eb5e230e1c"},
   "statistex": {:hex, :statistex, "1.1.0", "7fec1eb2f580a0d2c1a05ed27396a084ab064a40cfc84246dbfb0c72a5c761e5", [:mix], [], "hexpm", "f5950ea26ad43246ba2cce54324ac394a4e7408fdcf98b8e230f503a0cba9cf5"},
-  "statix": {:hex, :discord_statix, "1.7.0", "f84140caed09177da1952bef3f92eb9b94a1acc8c2de0b7826bf7a6002c017b6", [:mix], [], "hexpm", "3c316994c334d4d41d45cb5e2a67efb399327c4de5e65f01e52ab61eefd7eed9"},
+  "statix": {:hex, :discord_statix, "1.8.0", "11a5daa60029b39cfab2e11f7158bb1be3a426a9349731145184c3e257bd820a", [:mix], [], "hexpm", "a840f9c2f5789986830cb259e50947c5263c09eaf8c1662b9511f28e772a7acd"},
 }