(annotate-reaction {:keys [message-id]} id entry)
(peer-group-manager peer-config onyx-vpeer-system-fn)
(peer-group-manager-loop state)
(peers-allocated-proportion {:keys [group-state replica up?] :as state})
(poll-inbox! {:keys [inbox-ch] :as state})
(remove-shutdown-futs fs)
(safe-stop-vpeer! vpeer-component)
(setup-group-state {:keys [comm peer-config group-ch monitoring] :as state})
(shutting-down-task-metrics {:keys [shutting-down-futures
set-num-peer-shutdowns!
set-peer-shutdown-duration-ms!]
:as state})
(spin-until-tasks-shutdown state)
(start-communicator! {:keys [peer-config monitoring group-ch] :as state})
(transition-group entry old-replica new-replica diff group-state)
(transition-peers log entry old-replica new-replica diff peer-config vpeers)
(update-scheduler-lag! {:keys [set-scheduler-lag! inbox-entries]})
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close