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]})