package nsq

  1. Overview
  2. Docs

Module Nsq.ConsumerSource

Sourcemodule Config : sig ... end
Sourcetype t
Sourceval create : ?mode:[ `Nsqd | `Lookupd ] -> ?config:Config.t -> Address.t list -> Topic.t -> Channel.t -> (bytes -> [ `Ok | `Requeue ] Lwt.t) -> t
Sourceval run : t -> unit Lwt.t