package ocluster-worker

  1. Overview
  2. Docs

Module Cluster_worker.Log_dataSource

Sourceval max_chunk_size : int64
Sourcetype t = {
  1. data : Buffer.t;
  2. mutable cond : [ `Running of unit Lwt_condition.t | `Finished ];
}
Sourceval create : unit -> t
Sourceval stream : t -> start:int64 -> (string * int64) Lwt.t
Sourceval write : t -> string -> unit
Sourceval copy_from_stream : t -> Lwt_io.input_channel -> unit Lwt.t
Sourceval close : t -> unit
Sourceval info : t -> ('a, Format.formatter, unit, unit, unit, unit) format6 -> 'a