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

also handle the non force case

Browse source
This commit is contained in:
Simon Cruanes 2024-07-22 10:55:51 -04:00
parent 592814dab8
commit 5d5d909c18
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/client-ocurl/opentelemetry_client_ocurl.ml
View file

@ -289,8 +289,8 @@ end = struct
let batch_max_size_ = 200 let batch_max_size_ = 200
let should_send_batch_ ~config ~now (b : _ Batch.t) : bool = let should_send_batch_ ?(side = []) ~config ~now (b : _ Batch.t) : bool =
Batch.len b > 0 (Batch.len b > 0 || side != [])
&& (Batch.len b >= batch_max_size_ && (Batch.len b >= batch_max_size_
|| ||
let timeout = Mtime.Span.(config.Config.batch_timeout_ms * ms) in let timeout = Mtime.Span.(config.Config.batch_timeout_ms * ms) in
@ -355,7 +355,10 @@ end = struct
if Batch.len batches.traces > 0 then send_traces () if Batch.len batches.traces > 0 then send_traces ()
) else ( ) else (
let now = Mtime_clock.now () in let now = Mtime_clock.now () in
if should_send_batch_ ~config ~now batches.metrics then if
should_send_batch_ ~config ~now batches.metrics
~side:(AList.get gc_metrics)
then
send_metrics (); send_metrics ();
if should_send_batch_ ~config ~now batches.traces then send_traces (); if should_send_batch_ ~config ~now batches.traces then send_traces ();