simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-09 12:23:32 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix self_trace

Browse source
This commit is contained in:
Simon Cruanes 2025-12-04 01:07:41 -05:00
parent b91139509b
commit a643bc6c02
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/client/self_trace.ml
View file

@ -2,7 +2,7 @@ module OT = Opentelemetry
let enabled = Atomic.make false let enabled = Atomic.make false
let add_event (scope : OT.Scope.t) ev = OT.Scope.add_event scope (fun () -> ev) let[@inline] add_event (scope : OT.Span.t) ev = OT.Span.add_event scope ev
let dummy_trace_id_ = OT.Trace_id.dummy let dummy_trace_id_ = OT.Trace_id.dummy
@ -14,10 +14,11 @@ let with_ ?kind ?attrs name f =
OT.Tracer.with_ ?kind ?attrs name f OT.Tracer.with_ ?kind ?attrs name f
else ( else (
(* A new scope is needed here because it might be modified *) (* A new scope is needed here because it might be modified *)
let scope = let span : OT.Span.t =
OT.Scope.make ~trace_id:dummy_trace_id_ ~span_id:dummy_span_id () OT.Span.make ~trace_id:dummy_trace_id_ ~id:dummy_span_id ~start_time:0L
~end_time:0L name
in in
f scope f span
) )
let set_enabled b = Atomic.set enabled b let set_enabled b = Atomic.set enabled b

4
src/client/self_trace.mli
View file

@ -1,12 +1,12 @@
(** Mini tracing module (disabled if [config.self_trace=false]) *) (** Mini tracing module (disabled if [config.self_trace=false]) *)
val add_event : Opentelemetry.Scope.t -> Opentelemetry.Event.t -> unit val add_event : Opentelemetry.Span.t -> Opentelemetry.Event.t -> unit
val with_ : val with_ :
?kind:Opentelemetry.Span_kind.t -> ?kind:Opentelemetry.Span_kind.t ->
?attrs:(string * Opentelemetry.value) list -> ?attrs:(string * Opentelemetry.value) list ->
string -> string ->
(Opentelemetry.Scope.t -> 'a) -> (Opentelemetry.Span.t -> 'a) ->
'a 'a
val set_enabled : bool -> unit val set_enabled : bool -> unit