package nsq

  1. Overview
  2. Docs
module Config : sig ... end
type t
val create : ?mode:[ `Nsqd | `Lookupd ] -> ?config:Config.t -> Address.t list -> Topic.t -> Channel.t -> (bytes -> [ `Ok | `Requeue ] Lwt.t) -> t
val run : t -> unit Lwt.t