mirror of
https://github.com/ocaml-tracing/ocaml-opentelemetry.git
synced 2026-03-08 03:47:59 -04:00
62 lines
2.3 KiB
OCaml
62 lines
2.3 KiB
OCaml
module Client = Opentelemetry_client
|
|
module L = Opentelemetry_proto.Logs
|
|
module Res = Opentelemetry_proto.Resource
|
|
|
|
(* NOTE: This port must be different from that used by other integration tests,
|
|
to prevent socket binding clashes. *)
|
|
let port = 4399
|
|
|
|
let url = Printf.sprintf "http://localhost:%d" port
|
|
|
|
let cmd = [ "emit_logs_cohttp"; "--url"; url ]
|
|
|
|
let tests (signal_batches : Client.Resource_signal.t list) =
|
|
ignore signal_batches;
|
|
let cur_time = ref 0 in
|
|
List.iter
|
|
(fun (signal_batch : Client.Resource_signal.t) ->
|
|
match signal_batch with
|
|
| Logs ls ->
|
|
ls (* Mask out the times so tests don't change in between runs *)
|
|
|> List.map (fun (l : L.resource_logs) ->
|
|
let masked_resource =
|
|
l.resource
|
|
|> Option.map (fun (r : Res.resource) ->
|
|
let r = Res.copy_resource r in
|
|
(* just remove the metadata... *)
|
|
Res.resource_set_attributes r [];
|
|
r)
|
|
in
|
|
let masked_scope_logs =
|
|
List.map
|
|
(fun (sl : L.scope_logs) ->
|
|
let masked_log_records =
|
|
List.map
|
|
(fun (lr : L.log_record) ->
|
|
let lr = L.copy_log_record lr in
|
|
let pseudo_time = Int64.of_int !cur_time in
|
|
incr cur_time;
|
|
L.log_record_set_time_unix_nano lr pseudo_time;
|
|
L.log_record_set_observed_time_unix_nano lr
|
|
pseudo_time;
|
|
lr)
|
|
sl.log_records
|
|
in
|
|
let sl = L.copy_scope_logs sl in
|
|
L.scope_logs_set_log_records sl masked_log_records;
|
|
sl)
|
|
l.scope_logs
|
|
in
|
|
let l = L.copy_resource_logs l in
|
|
L.resource_logs_set_scope_logs l masked_scope_logs;
|
|
Option.iter (L.resource_logs_set_resource l) masked_resource;
|
|
l)
|
|
|> List.iter (Format.printf "%a\n" L.pp_resource_logs)
|
|
| _ -> ())
|
|
signal_batches
|
|
|
|
let () =
|
|
let signal_batches =
|
|
Lwt_main.run (Signal_gatherer.gather_signals ~port cmd)
|
|
in
|
|
tests signal_batches
|