simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-09 12:23:32 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

minor refactoring

Browse source
This commit is contained in:
Simon Cruanes 2022-04-12 09:39:42 -04:00
parent d69da69c48
commit 7af92b5589
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/client/opentelemetry_client_ocurl.ml
View file

@ -348,7 +348,7 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
let ((module C) as curl) = (module Curl() : CURL) in
let emit_metrics (l:Metrics.resource_metrics list list) =
let send_metrics_http (l:Metrics.resource_metrics list list) =
Pbrt.Encoder.reset encoder;
let resource_metrics =
List.fold_left (fun acc l -> List.rev_append l acc) [] l in
@ -369,7 +369,7 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
end;
in
let emit_traces (l:Trace.resource_spans list list) =
let send_traces_http (l:Trace.resource_spans list list) =
Pbrt.Encoder.reset encoder;
let resource_spans =
List.fold_left (fun acc l -> List.rev_append l acc) [] l in
@ -400,7 +400,7 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
let batch = ref [AList.pop_all gc_metrics] in
E_metrics.pop_iter_all (fun l -> batch := l :: !batch);
if not (batch_is_empty !batch) then (
emit_metrics !batch;
send_metrics_http !batch;
);
Atomic.set last_wakeup (Mtime_clock.now());
true
@ -411,7 +411,7 @@ let mk_emitter ~(config:Config.t) () : (module EMITTER) =
let batch = ref [] in
E_trace.pop_iter_all (fun l -> batch := l :: !batch);
if not (l_is_empty !batch) then (
emit_traces !batch;
send_traces_http !batch;
);
Atomic.set last_wakeup (Mtime_clock.now());
true