simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-08 20:07:55 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

in backends, call tick() before cleaning up

Browse source 
this helps flushing signals that are being batched.

close #69
This commit is contained in:
Simon Cruanes 2024-10-16 13:26:57 -04:00
parent a44c5dc33a
commit 424a82c8a5
2 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/client-cohttp-lwt/opentelemetry_client_cohttp_lwt.ml
View file

@ -569,7 +569,11 @@ let setup_ ?stop ?config () =
let backend = create_backend ?stop ?config () in let backend = create_backend ?stop ?config () in
let (module B : OT.Collector.BACKEND) = backend in let (module B : OT.Collector.BACKEND) = backend in
OT.Collector.set_backend backend; OT.Collector.set_backend backend;
B.cleanup let cleanup () =
B.tick ();
B.cleanup ()
in
cleanup
let setup ?stop ?config ?(enable = true) () = let setup ?stop ?config ?(enable = true) () =
if enable then ( if enable then (

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

@ -509,7 +509,11 @@ let setup_ ?(stop = Atomic.make false) ?(config : Config.t = Config.make ()) ()
ignore (setup_ticker_thread ~stop ~sleep_ms backend () : Thread.t) ignore (setup_ticker_thread ~stop ~sleep_ms backend () : Thread.t)
); );
B.cleanup let cleanup () =
B.tick ();
B.cleanup ()
in
cleanup
let setup ?stop ?config ?(enable = true) () = let setup ?stop ?config ?(enable = true) () =
if enable then ( if enable then (