Liking cljdoc? Tell your friends :D
Clojure only.

onyx.messaging.messenger-state

build-final-publication-infoclj

(build-final-publication-info peer-opts
                              job-id
                              src-peer-id
                              serialized-task
                              [[site dst-task-id slot-id short-id] dsts])
source

messenger-connectionsclj

(messenger-connections
  {:keys [allocations peer-sites message-short-ids in->out] :as replica}
  {:keys [onyx.core/workflow onyx.core/catalog onyx.core/task
          onyx.core/serialized-task onyx.core/job-id onyx.core/id
          onyx.core/peer-opts]
   :as event})
source

next-messenger-state!clj

(next-messenger-state! messenger
                       {:keys [onyx.core/job-id] :as event}
                       old-replica
                       new-replica)
source

transition-messengerclj

(transition-messenger messenger new-replica-version new-pub-subs)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

Keyboard shortcutsReport a problemcljdoc on GitHub
× close