Collector_tef (trace-tef.trace-tef.Trace_tef.Collector

Sourcemodule Buf_pool : sig ... end

Sourcetype t

Main state.

val create : 
  ?buf_pool:Buf_pool.t ->
  pid:int ->
  exporter:Exporter.t ->
  unit ->
  t

Create a fresh state.

Sourceval flush : t -> unit

Sourceval close : t -> unit

Sourceval active : t -> bool

Sourceval callbacks_collector : t Trace_core.Collector.Callbacks.t

Callbacks used for the subscriber

Sourceval collector : t -> Trace_core.Collector.t

Subscriber that writes json into this writer