mirror of
https://github.com/ocaml-tracing/ocaml-opentelemetry.git
synced 2026-03-09 12:23:32 -04:00
fix self_trace
This commit is contained in:
parent
c009b1d20a
commit
e29ec44561
2 changed files with 7 additions and 6 deletions
|
|
@ -2,7 +2,7 @@ module OT = Opentelemetry
|
|||
|
||||
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
|
||||
|
||||
|
|
@ -14,10 +14,11 @@ let with_ ?kind ?attrs name f =
|
|||
OT.Tracer.with_ ?kind ?attrs name f
|
||||
else (
|
||||
(* A new scope is needed here because it might be modified *)
|
||||
let scope =
|
||||
OT.Scope.make ~trace_id:dummy_trace_id_ ~span_id:dummy_span_id ()
|
||||
let span : OT.Span.t =
|
||||
OT.Span.make ~trace_id:dummy_trace_id_ ~id:dummy_span_id ~start_time:0L
|
||||
~end_time:0L name
|
||||
in
|
||||
f scope
|
||||
f span
|
||||
)
|
||||
|
||||
let set_enabled b = Atomic.set enabled b
|
||||
|
|
|
|||
|
|
@ -1,12 +1,12 @@
|
|||
(** 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_ :
|
||||
?kind:Opentelemetry.Span_kind.t ->
|
||||
?attrs:(string * Opentelemetry.value) list ->
|
||||
string ->
|
||||
(Opentelemetry.Scope.t -> 'a) ->
|
||||
(Opentelemetry.Span.t -> 'a) ->
|
||||
'a
|
||||
|
||||
val set_enabled : bool -> unit
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue