package opentelemetry

You can search for identifiers within the package.

in-package search v0.2.0

Instrumentation for https://opentelemetry.io

Install

dune-project

Dependency

github.com Readme Changelog Edit opam file Versions (13)

Authors

T

the Imandra team and contributors

Maintainers

Sources

opentelemetry-0.12.tbz

sha256=ca92e7395495f73b46316607c514ce0dbe5fab129dddd9a17b353f835dcbf77d

sha512=ea2afd07c8db955364681f90388959db97d7b7f5b0836bc4045eca929968d6d77905e3aa66802226c0791c2552d0e281bdf2dbfe7ed90e9877ce3cedc343823f

doc/opentelemetry.client/Opentelemetry_client/Batch/index.html

Module `Opentelemetry_client.Batch`Source

A thread-safe batch of resources to be popper when ready .

Sourcetype 'a t

Source

val make : 
  ?batch:int ->
  ?high_watermark:int ->
  ?now:Mtime.t ->
  ?timeout:Mtime.span ->
  unit ->
  'a t

make () is a new batch

parameter batch
the number of elements after which the batch will be considered full, and ready to pop. Set to 0 to disable batching. It is required that batch >= 0. Default 1.

parameter high_watermark
the batch size limit after which new elements will be `Dropped by push. This prevents the queue from growing too fast for effective transmission in case of signal floods. Default if batch = 1 then 100 else batch * 10.

parameter now
the current time. Default Mtime_clock.now ().

parameter timeout
the time span after which a batch is ready to pop, whether or not it is full.

Sourceval pop_if_ready : ?force:bool -> now:Mtime.t -> 'a t -> 'a list option

pop_if_ready ~now b is Some xs, where is xs includes all the elements pushed since the last batch, if the batch ready to be emitted.

A batch is ready to pop if it contains some elements and

batching is disabled, and any elements have been batched, or batching was enabled and at least batch elements have been pushed, or
a timeout was provided, and more than a timeout span has passed since the last pop was ready, or
the pop is forced,

parameter now
the current time

parameter force
override the other batch conditions, for when when we just want to emit batches before exit or because the user asks for it

Sourceval push : 'a t -> 'a list -> [ `Dropped | `Ok ]

push b xs is `Ok if it succeeds in pushing the values in xs into the batch b, or `Dropped if the current size of the batch has exceeded the high water mark determined by the batch argument to {!make}. )