package opentelemetry-client

  1. Overview
  2. Docs
package opentelemetry-client
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module Bounded_queue.RecvSource

Receiving side

Sourcetype 'a t = {
  1. on_non_empty : (unit -> unit) -> unit;
    (*

    on_non_empty f registers f to be called whenever the queue transitions from empty to non-empty.

    *)
  2. try_pop : unit -> 'a pop_result;
    (*

    Try to pop an item right now.

    *)
  3. common : Common.t;
}
Sourceval try_pop : 'a t -> 'a pop_result
Sourceval on_non_empty : 'a t -> (unit -> unit) -> unit
Sourceval closed : 'a t -> bool
Sourceval num_discarded : 'a t -> int
Sourceval size : 'a t -> int
Sourceval high_watermark : 'a t -> int
Sourceval map : ('a -> 'b) -> 'a t -> 'b t