Collector_tef (trace-tef.Trace_tef.Collector

module Buf_pool : sig ... end

type t

Main state.

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

Create a fresh state.

val flush : t -> unit

val close : t -> unit

val active : t -> bool

val callbacks_collector : t Trace_core.Collector.Callbacks.t

Callbacks used for the subscriber

val collector : t -> Trace_core.Collector.t

Subscriber that writes json into this writer