onyx.peer.peer-group-manager

->PeerGroupManager
(->PeerGroupManager peer-config onyx-vpeer-system-fn)
Positional factory function for class onyx.peer.peer_group_manager.PeerGroupManager.

action
multimethod
annotate-reaction
(annotate-reaction {:keys [message-id]} id entry)
futures-stuck-park-ms
idle-backoff-ms
map->PeerGroupManager
(map->PeerGroupManager m__6522__auto__)
Factory function for class onyx.peer.peer_group_manager.PeerGroupManager, taking a map of keywords to field values.

media-driver-backoff-ms
peer-group-error-backoff-ms
peer-group-manager
(peer-group-manager peer-config onyx-vpeer-system-fn)
peer-group-manager-loop
(peer-group-manager-loop state)
peers-allocated-proportion
(peers-allocated-proportion {:keys [group-state replica up?], :as state})
poll-inbox!
(poll-inbox! {:keys [inbox-ch], :as state})
remove-shutdown-futs
(remove-shutdown-futs fs)
safe-stop-vpeer!
(safe-stop-vpeer! vpeer-component)
setup-group-state
(setup-group-state {:keys [comm peer-config group-ch monitoring], :as state})
shutting-down-task-metrics
(shutting-down-task-metrics {:keys [shutting-down-futures set-num-peer-shutdowns! set-peer-shutdown-duration-ms!], :as state})
spin-park-ms
spin-until-tasks-shutdown
(spin-until-tasks-shutdown state)
start-communicator!
(start-communicator! {:keys [peer-config monitoring group-ch], :as state})
transition-group
(transition-group entry old-replica new-replica diff group-state)
transition-peers
(transition-peers log entry old-replica new-replica diff peer-config vpeers)
update-scheduler-lag!
(update-scheduler-lag! {:keys [set-scheduler-lag! inbox-entries]})