Liking cljdoc? Tell your friends :D
Clojure only.

onyx.scheduling.common-job-scheduler

actual-usageclj

(actual-usage replica jobs)
source

add-allocation-versionsclj

(add-allocation-versions new old)

Adds version numbers to jobs whenever an allocation changes for that job. This gives a measure of validity of messages and barriers that transit through the system.

Adds version numbers to jobs whenever an allocation changes for that job.
This gives a measure of validity of messages and barriers that transit through the system.
sourceraw docstring

add-messaging-short-idsclj

(add-messaging-short-ids replica)

Converts long form messaging identifies into short int identifiers, for quick comparison and reduced message size.

Converts long form messaging identifies into short int identifiers, for
quick comparison and reduced message size.
sourceraw docstring

anti-jitter-constraintsclj

(anti-jitter-constraints replica
                         jobs
                         task-seq
                         peer->vm
                         task->node
                         planned-capacities)

Reduces the amount of 'jitter' - that is unnecessary movement from a peer between tasks. If the actual capacity is greater than or equal to the planned capacity, we shouldn't reallocate the peers. BtrPlace has a Fence constraint that lets us express just that.

Reduces the amount of 'jitter' - that is unnecessary movement
from a peer between tasks. If the actual capacity is greater than
or equal to the planned capacity, we shouldn't reallocate the peers.
BtrPlace has a Fence constraint that lets us express just that.
sourceraw docstring

assign-coordinatorsclj

(assign-coordinators {:keys [coordinators allocations] :as replica})
source

assign-task-resourcesclj

(assign-task-resources new-replica original-replica peer->task)
source

assign-task-slot-idsclj

(assign-task-slot-ids new-replica original peer->task)
source

btr-place-schedulingclj

(btr-place-scheduling replica jobs job-utilization capacities)
source

build-current-modelclj

(build-current-model replica mapping task->node peer->vm)
source

build-job-and-task->nodeclj

(build-job-and-task->node model task-seq)
source

build-node->taskclj

(build-node->task task->node)
source

build-peer->taskclj

(build-peer->task result-model peer->vm node->task)
source

build-peer->vmclj

(build-peer->vm replica model)
source

calculate-capacityclj

(calculate-capacity replica task-capacities task->node [job-id task-id :as id])
source

capacity-constraintsclj

(capacity-constraints replica
                      job-utilization
                      task-seq
                      task->node
                      planned-capacities)
source

change-peer-allocationsclj

(change-peer-allocations replica peer->task)
source

claim-spare-peerscljmultimethod

source

constrainted-tasks-for-peerclj

(constrainted-tasks-for-peer replica jobs peer-tags)
source

deallocate-starved-jobsclj

(deallocate-starved-jobs replica)

Strips out allocations from jobs that no longer meet the minimum number of peers. This can happen if a peer leaves from a running job.

Strips out allocations from jobs that no longer meet the minimum number
of peers. This can happen if a peer leaves from a running job.
sourceraw docstring

full-allocation?clj

(full-allocation? replica utilization planned-capacities)
source

grouped-task?clj

(grouped-task? replica job-id task-id)
source

grouping-task-constraintsclj

(grouping-task-constraints replica task-seq task->node peer->vm)
source

input-task?clj

(input-task? replica job-id task-id)
source

job->planned-task-capacityclj

(job->planned-task-capacity replica jobs-ids utilization)
source

job-claim-peersclj

(job-claim-peers replica job-offers)
source

job-coverable?clj

(job-coverable? replica job n)
source

job-lower-boundclj

(job-lower-bound replica job)
source

job-offer-n-peerscljmultimethod

source

job-upper-boundclj

(job-upper-bound replica job)
source

messaging-long-formclj

(messaging-long-form {:keys [allocations in->out] :as replica})
source

n-no-op-tasksclj

(n-no-op-tasks replica capacities task-seq)
source

n-qualified-peersclj

(n-qualified-peers replica peers job)
source

no-tagged-peers-constraintsclj

(no-tagged-peers-constraints replica peers peer->vm task->node jobs no-op-node)
source

peer-running-constraintsclj

(peer-running-constraints peer->vm)
source

reallocate-peersclj

(reallocate-peers replica)
source

reconfigure-cluster-workloadclj

(reconfigure-cluster-workload new old)
source

remove-jobclj

(remove-job replica job)
source

slot-idsclj

(slot-ids replica job-id task-id)
source

src-peersclj

(src-peers {:keys [allocations in->out input-tasks] :as replica} job task)
source

task-tagged-constraintsclj

(task-tagged-constraints replica peers peer->vm task->node jobs no-op-node)
source

to-node-arrayclj

(to-node-array nodes)
source

unassign-task-slot-idsclj

(unassign-task-slot-ids new-replica original-replica peer->task)
source

unconstrained-tasksclj

(unconstrained-tasks replica jobs)
source

unrolled-tasksclj

(unrolled-tasks replica task-utilization)
source

update-peer-siteclj

(update-peer-site replica job-id task-id peer-id)
source

update-slot-id-for-peerclj

(update-slot-id-for-peer replica job-id task-id peer-id)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

Keyboard shortcutsReport a problemcljdoc on GitHub
× close