onyx.scheduling.colocated-task-scheduler — org.onyxplatform/onyx 0.14.2

ban-smaller-sites clj

(ban-smaller-sites replica jobs peer->vm task->node large-sites rejected)

choose-candidates clj

(choose-candidates replica peer-config this-peer downstream-peers)

find-colocated-peers clj

(find-colocated-peers replica this-peer other-peers)

get-peer-site clj

(get-peer-site replica p)

global-saturation-lower-bound clj

(global-saturation-lower-bound replica job-id task-ids)

large-enough-sites clj

(large-enough-sites site->peers-mapping min-peers)

non-colocated-tasks clj

(non-colocated-tasks replica jobs)

select-peers clj

(select-peers site->peers total size)

site->peers clj

(site->peers replica)