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

Merge pull request #7 from AestheticIntegration/dave-and-matt/sync-lwt-collection

Browse source 
Dave and matt/sync lwt collection
This commit is contained in:
Dave Aitken 2022-03-24 14:45:52 +00:00 • committed by GitHub
commit 9e0cd0acc9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/lwt/opentelemetry_lwt.ml
View file

@ -12,14 +12,6 @@ module Trace = struct
open Proto.Trace open Proto.Trace
include Trace include Trace
(** Emit asynchronously *)
let emit ?service_name ?attrs (spans:span list) : unit Lwt.t =
let fut, wake = Lwt.wait() in
let rs = make_resource_spans ?service_name ?attrs spans in
Collector.send_trace [rs]
~over:(fun () -> Lwt.wakeup_later wake ())
~ret:(fun () -> fut)
(** Sync span guard *) (** Sync span guard *)
let with_ let with_
?trace_state ?service_name ?(attrs=[]) ?trace_state ?service_name ?(attrs=[])
@ -44,10 +36,10 @@ module Trace = struct
Lwt.catch Lwt.catch
(fun () -> (fun () ->
let* x = f scope in let* x = f scope in
let+ () = finally (Ok ()) in let () = finally (Ok ()) in
x) Lwt.return x)
(fun e -> (fun e ->
let* () = finally (Error (Printexc.to_string e)) in let () = finally (Error (Printexc.to_string e)) in
Lwt.fail e) Lwt.fail e)
end end