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

client config: add http_concurrency_level option

Browse source
This commit is contained in:
Simon Cruanes 2025-12-05 15:02:49 -05:00
parent 53335468d9
commit 703755e775
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 13 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/client/client_config.ml
View file

@ -9,6 +9,7 @@ type t = {
batch_logs: int option; batch_logs: int option;
batch_timeout_ms: int; batch_timeout_ms: int;
self_trace: bool; self_trace: bool;
http_concurrency_level: int option;
} }
let pp out (self : t) : unit = let pp out (self : t) : unit =
@ -26,15 +27,17 @@ let pp out (self : t) : unit =
batch_metrics; batch_metrics;
batch_logs; batch_logs;
batch_timeout_ms; batch_timeout_ms;
http_concurrency_level;
} = } =
self self
in in
Format.fprintf out Format.fprintf out
"{@[ debug=%B;@ self_trace=%B; url_traces=%S;@ url_metrics=%S;@ \ "{@[ debug=%B;@ self_trace=%B; url_traces=%S;@ url_metrics=%S;@ \
url_logs=%S;@ headers=%a;@ batch_traces=%a;@ batch_metrics=%a;@ \ url_logs=%S;@ headers=%a;@ batch_traces=%a;@ batch_metrics=%a;@ \
batch_logs=%a;@ batch_timeout_ms=%d @]}" batch_logs=%a;@ batch_timeout_ms=%d;@ http_concurrency_level=%a @]}"
debug self_trace url_traces url_metrics url_logs ppheaders headers ppiopt debug self_trace url_traces url_metrics url_logs ppheaders headers ppiopt
batch_traces ppiopt batch_metrics ppiopt batch_logs batch_timeout_ms batch_traces ppiopt batch_metrics ppiopt batch_logs batch_timeout_ms ppiopt
http_concurrency_level
let default_url = "http://localhost:4318" let default_url = "http://localhost:4318"
@ -50,6 +53,7 @@ type 'k make =
?headers:(string * string) list -> ?headers:(string * string) list ->
?batch_timeout_ms:int -> ?batch_timeout_ms:int ->
?self_trace:bool -> ?self_trace:bool ->
?http_concurrency_level:int ->
'k 'k
module type ENV = sig module type ENV = sig
@ -123,7 +127,8 @@ module Env () : ENV = struct
let make k ?(debug = get_debug ()) ?url ?url_traces ?url_metrics ?url_logs let make k ?(debug = get_debug ()) ?url ?url_traces ?url_metrics ?url_logs
?(batch_traces = Some 400) ?(batch_metrics = Some 20) ?(batch_traces = Some 400) ?(batch_metrics = Some 20)
?(batch_logs = Some 400) ?(headers = get_headers ()) ?(batch_logs = Some 400) ?(headers = get_headers ())
?(batch_timeout_ms = 2_000) ?(self_trace = false) = ?(batch_timeout_ms = 2_000) ?(self_trace = false) ?http_concurrency_level
=
(* Ensure the state is synced, in case these values are passed in explicitly *) (* Ensure the state is synced, in case these values are passed in explicitly *)
set_debug debug; set_debug debug;
set_headers headers; set_headers headers;
@ -165,5 +170,6 @@ module Env () : ENV = struct
batch_logs; batch_logs;
batch_timeout_ms; batch_timeout_ms;
self_trace; self_trace;
http_concurrency_level;
} }
end end

4
src/client/client_config.mli
View file

@ -32,6 +32,9 @@ type t = private {
(** If true, the OTEL library will also emit its own spans. Default (** If true, the OTEL library will also emit its own spans. Default
[false]. [false].
@since 0.7 *) @since 0.7 *)
http_concurrency_level: int option;
(** How many HTTP requests can be done simultaneously (at most)?
@since NEXT_RELEASE *)
} }
(** Configuration. (** Configuration.
@ -55,6 +58,7 @@ type 'k make =
?headers:(string * string) list -> ?headers:(string * string) list ->
?batch_timeout_ms:int -> ?batch_timeout_ms:int ->
?self_trace:bool -> ?self_trace:bool ->
?http_concurrency_level:int ->
'k 'k
(** A function that gathers all the values needed to construct a {!t}, and (** A function that gathers all the values needed to construct a {!t}, and
produces a ['k]. ['k] is typically a continuation used to construct a produces a ['k]. ['k] is typically a continuation used to construct a