simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-11 21:18:33 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

refine seld tracing

Browse source
This commit is contained in:
Simon Cruanes 2023-12-20 14:26:07 -05:00
parent f0750cdfb5
commit 3d16de634f
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/client-ocurl/opentelemetry_client_ocurl.ml
View file

@ -147,11 +147,18 @@ end = struct
("Content-Type", "application/x-protobuf") :: config.headers ("Content-Type", "application/x-protobuf") :: config.headers
in in
match match
let@ _sc =
Trace'.with_ ~kind:Span.Span_kind_internal "curl.post"
~attrs:[ "sz", `Int (String.length data) ]
in
Ezcurl.post ~headers ~client ~params:[] ~url ~content:(`String data) () Ezcurl.post ~headers ~client ~params:[] ~url ~content:(`String data) ()
with with
| Ok { code; _ } when code >= 200 && code < 300 -> () | Ok { code; _ } when code >= 200 && code < 300 -> ()
| Ok { code; body; headers = _; info = _ } -> | Ok { code; body; headers = _; info = _ } ->
Atomic.incr n_errors; Atomic.incr n_errors;
Trace'.add_event _sc (fun () ->
Opentelemetry.Event.make "error" ~attrs:[ "code", `Int code ]);
if !debug_ || config.debug then ( if !debug_ || config.debug then (
let dec = Pbrt.Decoder.of_string body in let dec = Pbrt.Decoder.of_string body in
let body = let body =