onyx.plugin.messaging-output
->MessengerOutput
(->MessengerOutput segment-buf routes idx size queued-offers failed-add full-pub)Positional factory function for class onyx.plugin.messaging_output.MessengerOutput.
add-segment
(add-segment segment-buf stored-routes size segment event root leaves)new-messenger-output
(new-messenger-output {:keys [onyx.core/task-map onyx.core/peer-opts], :as event})try-sends
(try-sends pubs)