diff --git a/lib/req_telemetry.ex b/lib/req_telemetry.ex index 9006080..10e0508 100644 --- a/lib/req_telemetry.ex +++ b/lib/req_telemetry.ex @@ -239,7 +239,14 @@ defmodule ReqTelemetry do :telemetry.execute( [:req, :request, event, :start], %{time: System.system_time()}, - %{ref: ref, url: url, method: method, headers: headers, metadata: metadata(req)} + %{ + ref: ref, + url: url, + method: method, + headers: headers, + request: req, + metadata: metadata(req) + } ) Req.Request.put_private(req, :telemetry, Map.put(private, event, start_time)) @@ -266,6 +273,8 @@ defmodule ReqTelemetry do method: method, status: status, resp_headers: headers, + request: req, + response: resp, metadata: metadata(req) } ) @@ -291,6 +300,7 @@ defmodule ReqTelemetry do method: method, headers: headers, error: exception, + request: req, metadata: metadata(req) } ) diff --git a/test/req_telemetry_test.exs b/test/req_telemetry_test.exs index 0b08c6c..95c3864 100644 --- a/test/req_telemetry_test.exs +++ b/test/req_telemetry_test.exs @@ -199,7 +199,9 @@ defmodule ReqTelemetryTest do url: %URI{}, method: :post, resp_headers: ^resp_headers, - status: ^resp_status + status: ^resp_status, + request: %Req.Request{}, + response: %Req.Response{status: 201, body: ""} }} end end