onyx.peer.peer-group-manager — org.onyxplatform/onyx 0.13.3-alpha1

action clj multimethod

annotate-reaction clj

(annotate-reaction {:keys [message-id]} id entry)

futures-stuck-park-ms clj

idle-backoff-ms clj

media-driver-backoff-ms clj

peer-group-error-backoff-ms clj

peer-group-manager clj

(peer-group-manager peer-config onyx-vpeer-system-fn)

peer-group-manager-loop clj

(peer-group-manager-loop state)

peers-allocated-proportion clj

(peers-allocated-proportion {:keys [group-state replica up?] :as state})

poll-inbox! clj

(poll-inbox! {:keys [inbox-ch] :as state})

remove-shutdown-futs clj

(remove-shutdown-futs fs)

safe-stop-vpeer! clj

(safe-stop-vpeer! vpeer-component)

setup-group-state clj

(setup-group-state {:keys [comm peer-config group-ch monitoring] :as state})

shutting-down-task-metrics clj

(shutting-down-task-metrics {:keys [shutting-down-futures
                                    set-num-peer-shutdowns!
                                    set-peer-shutdown-duration-ms!]
                             :as state})

spin-park-ms clj

spin-until-tasks-shutdown clj

(spin-until-tasks-shutdown state)

start-communicator! clj

(start-communicator! {:keys [peer-config monitoring group-ch] :as state})

transition-group clj

(transition-group entry old-replica new-replica diff group-state)

transition-peers clj

(transition-peers log entry old-replica new-replica diff peer-config vpeers)

update-scheduler-lag! clj

(update-scheduler-lag! {:keys [set-scheduler-lag! inbox-entries]})