From 01fc804ab2347568e4fe6f7de79e6400d5a5b023 Mon Sep 17 00:00:00 2001 From: Yordis Prieto Date: Mon, 14 Nov 2022 17:33:48 -0500 Subject: [PATCH] chore: add semantic conventions pgk to redix (#119) --- .../opentelemetry_redix/lib/opentelemetry_redix.ex | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/instrumentation/opentelemetry_redix/lib/opentelemetry_redix.ex b/instrumentation/opentelemetry_redix/lib/opentelemetry_redix.ex index 7c27e9c..21333be 100644 --- a/instrumentation/opentelemetry_redix/lib/opentelemetry_redix.ex +++ b/instrumentation/opentelemetry_redix/lib/opentelemetry_redix.ex @@ -15,9 +15,11 @@ defmodule OpentelemetryRedix do """ + alias OpenTelemetry.SemanticConventions.Trace alias OpentelemetryRedix.Command alias OpentelemetryRedix.ConnectionTracker + require Trace require OpenTelemetry.Tracer @typedoc "Setup options" @@ -54,9 +56,9 @@ defmodule OpentelemetryRedix do attributes = %{ - "db.system": "redis", - "db.operation": operation, - "db.statement": statement + Trace.db_system() => "redis", + Trace.db_operation() => operation, + Trace.db_statement() => statement } |> Map.merge(net_attributes(connection)) |> Map.merge(redix_attributes(meta)) @@ -77,7 +79,7 @@ defmodule OpentelemetryRedix do defp net_attributes(%{address: address}) when is_binary(address) do [host, port] = address |> String.split(":") - %{"net.peer.name": host, "net.peer.port": port} + %{Trace.net_peer_name() => host, Trace.net_peer_port() => port} end defp net_attributes(_), do: %{}