simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-08 20:07:55 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

otel-ocurl: some self-tracing

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

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

@ -5,6 +5,7 @@
module OT = Opentelemetry module OT = Opentelemetry
module Config = Config module Config = Config
module Trace' = Opentelemetry.Trace
open Opentelemetry open Opentelemetry
include Common_ include Common_
@ -120,9 +121,17 @@ end = struct
let send_http_ ~stop ~config (client : Curl.t) encoder ~path ~encode x : unit let send_http_ ~stop ~config (client : Curl.t) encoder ~path ~encode x : unit
= =
Pbrt.Encoder.reset encoder; let@ _sc =
encode x encoder; Trace'.with_ ~kind:Span.Span_kind_producer "otel-ocurl.send-http"
let data = Pbrt.Encoder.to_string encoder in in
let data =
let@ _sc = Trace'.with_ ~kind:Span.Span_kind_internal "encode-proto" in
Pbrt.Encoder.reset encoder;
encode x encoder;
Pbrt.Encoder.to_string encoder
in
let url = let url =
let url = config.Config.url in let url = config.Config.url in
if url <> "" && String.get url (String.length url - 1) = '/' then if url <> "" && String.get url (String.length url - 1) = '/' then