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

compat 4.08

Browse source
This commit is contained in:
Simon Cruanes 2026-01-12 21:09:58 -05:00
parent 610244aad4
commit 0099bc5439
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
tests/client_e2e/clients_e2e_lib.ml
View file

@ -32,11 +32,11 @@ let signals_from_batch (signal_batch : Client.Resource_signal.t) =
let filter_map_spans f signals = let filter_map_spans f signals =
signals signals
|> List.concat_map (function |> CCList.flat_map (function
| `Log _ | `Metric _ -> [] | `Log _ | `Metric _ -> []
| `Trace (r : Proto.Trace.resource_spans) -> | `Trace (r : Proto.Trace.resource_spans) ->
r.scope_spans r.scope_spans
|> List.concat_map (fun ss -> |> CCList.flat_map (fun ss ->
ss.Proto.Trace.spans |> List.filter_map f)) ss.Proto.Trace.spans |> List.filter_map f))
let count_spans_with_name name signals = let count_spans_with_name name signals =
@ -50,11 +50,11 @@ let count_spans_with_name name signals =
let filter_map_metrics f signals = let filter_map_metrics f signals =
signals signals
|> List.concat_map (function |> CCList.flat_map (function
| `Log _ | `Trace _ -> [] | `Log _ | `Trace _ -> []
| `Metric (r : Proto.Metrics.resource_metrics) -> | `Metric (r : Proto.Metrics.resource_metrics) ->
r.scope_metrics r.scope_metrics
|> List.concat_map (fun ss -> |> CCList.flat_map (fun ss ->
ss.Proto.Metrics.metrics |> List.filter_map f)) ss.Proto.Metrics.metrics |> List.filter_map f))
let count_metrics_with_name name signals = let count_metrics_with_name name signals =
@ -91,11 +91,11 @@ let get_metric_values name signals =
let filter_map_logs (f : Proto.Logs.log_record -> 'a option) signals : 'a list = let filter_map_logs (f : Proto.Logs.log_record -> 'a option) signals : 'a list =
signals signals
|> List.concat_map (function |> CCList.flat_map (function
| `Metric _ | `Trace _ -> [] | `Metric _ | `Trace _ -> []
| `Log (r : Proto.Logs.resource_logs) -> | `Log (r : Proto.Logs.resource_logs) ->
r.scope_logs r.scope_logs
|> List.concat_map (fun ss -> |> CCList.flat_map (fun ss ->
ss.Proto.Logs.log_records |> List.filter_map f)) ss.Proto.Logs.log_records |> List.filter_map f))
let count_logs_with_body p signals = let count_logs_with_body p signals =