simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-07 18:37:56 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

more self tracing

Browse source
This commit is contained in:
Simon Cruanes 2025-12-10 11:41:54 -05:00
parent 212ff39d0b
commit ed69b89bf1
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 19 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
src/client/generic_consumer.ml
View file

@ -57,6 +57,8 @@ end = struct
active_trigger: Aswitch.trigger;
config: config;
sender_config: Sender.config;
m_spans: int Atomic.t;
m_logs: int Atomic.t;
}
let shutdown self : unit =
@ -100,6 +102,12 @@ end = struct
let send_signals (self : state) (sender : Sender.t) ~backoff
(sigs : OTEL.Any_signal_l.t) : unit IO.t =
(match sigs with
| Spans l ->
ignore (Atomic.fetch_and_add self.m_spans (List.length l) : int)
| Logs l -> ignore (Atomic.fetch_and_add self.m_logs (List.length l) : int)
| Metrics _l -> ());
let* r = Sender.send sender sigs in
match r with
| Ok () ->
@ -174,6 +182,8 @@ end = struct
notify = Notifier.create ();
config;
sender_config;
m_spans = Atomic.make 0;
m_logs = Atomic.make 0;
}
in
@ -194,12 +204,17 @@ end = struct
self
let self_metrics (_self : state) : OTEL.Metrics.t list =
let self_metrics (self : state) : OTEL.Metrics.t list =
let open OTEL.Metrics in
let now = Mtime_clock.now () in
let now = OTEL.Timestamp_ns.now_unix_ns () in
let attrs = [ "otel.component.name", `String "otel_ocaml" ] in
[
sum ~name:"otel_ocaml.export.errors" ~is_monotonic:true
[ int ~now:(Mtime.to_uint64_ns now) (Atomic.get n_errors) ];
sum ~name:"otel.sd.exporter.errors" ~is_monotonic:true
[ int ~now (Atomic.get n_errors) ~attrs ];
sum ~name:"otel.sdk.exporter.span.exported" ~is_monotonic:true
[ int ~now (Atomic.get self.m_spans) ~attrs ];
sum ~name:"otel.sdk.exporter.log.exported" ~is_monotonic:true
[ int ~now (Atomic.get self.m_logs) ~attrs ];
]
let to_consumer (self : state) : Consumer.t =