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

docs

Browse source
This commit is contained in:
Simon Cruanes 2026-01-12 20:09:04 -05:00
parent 513aafe6e8
commit 07d8357cfb
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/client/generic_consumer.ml
View file

@ -1,3 +1,5 @@
(** A consumer: pulls signals from a queue, sends them somewhere else *)
open Common_
type error = Export_error.t
@ -7,16 +9,20 @@ let n_errors = Atomic.make 0
module type IO = Generic_io.S_WITH_CONCURRENCY
(** Generic sender: where to send signals *)
module type SENDER = sig
module IO : IO
type t
(** Sender state *)
type config
val create : config:config -> unit -> t
val cleanup : t -> unit
(** Cleanup resources once we are done. The sender cannot be used anymore
after this is called on it *)
val send : t -> OTEL.Any_signal_l.t -> (unit, error) result IO.t
end