package opentelemetry-client

  1. Overview
  2. Docs
Client SDK for https://opentelemetry.io

Install

dune-project
 Dependency

Authors

Maintainers

Sources

opentelemetry-0.91.1.tbz
sha256=30f344e7168a793d02c12d69c0f566b06eb963f52db3321e415ef6c5cd3d504d
sha512=19160da37cab59a23333d815baa67035f666e700a386953ec9957c685a0b72fa87919bac6a6651e50b1619773b3be7170bcc067c2d5316436b988bcf8d18dcba

doc/opentelemetry-client.sync/Opentelemetry_client_sync/Sync_queue/index.html

Module Opentelemetry_client_sync.Sync_queueSource

Simple blocking queue

Sourcetype 'a t
Sourceval create : unit -> _ t
Sourceexception Closed
Sourceval push : 'a t -> 'a -> unit

push q x pushes x into q, and returns ().

  • raises Closed

    if close q was previously called.

Sourceval pop : 'a t -> 'a

pop q pops the next element in q. It might block until an element comes.

  • raises Closed

    if the queue was closed before a new element was available.

Sourceval pop_all : 'a t -> 'a Queue.t -> unit

pop_all q into pops all the elements of q and moves them into into. if no element is available, it will block until it successfully transfers at least one item to into.

  • raises Closed

    if the queue was closed before a new element was available.

Sourceval close : _ t -> unit

Close the queue, meaning there won't be any more push allowed.