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

todo

Browse source
This commit is contained in:
Simon Cruanes 2025-12-05 23:33:32 -05:00
parent 97011b5693
commit ad158b15da
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 28 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
src/client/generic_http_consumer.ml
View file

@ -5,6 +5,34 @@ type error = Export_error.t
(** Number of errors met during export *)
let n_errors = Atomic.make 0
(* TODO: put this somewhere with an interval limiter to 30s
(* there is a possible race condition here, as several threads might update
metrics at the same time. But that's harmless. *)
if add_own_metrics then (
Atomic.set last_sent_metrics now;
let open OT.Metrics in
[
make_resource_metrics
[
sum ~name:"otel.export.dropped" ~is_monotonic:true
[
int
~start_time_unix_nano:(Mtime.to_uint64_ns last_emit)
~now:(Mtime.to_uint64_ns now) (Atomic.get n_dropped);
];
sum ~name:"otel.export.errors" ~is_monotonic:true
[
int
~start_time_unix_nano:(Mtime.to_uint64_ns last_emit)
~now:(Mtime.to_uint64_ns now) (Atomic.get n_errors);
];
];
]
) else
[]
*)
module type IO = Generic_io.S_WITH_CONCURRENCY
module type HTTPC = sig