onyx.log.commands.common — org.onyxplatform/onyx 0.14.5-SNAPSHOT

allocations->peers clj

(allocations->peers allocations)

build-stop-task-fn clj

(build-stop-task-fn external-kill-flag started-task-ch)

grouped-task? clj

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

input-task? clj

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

job->peers clj

(job->peers replica)

job-allocations->peer-ids clj

(job-allocations->peer-ids allocations job-id)

job-peer-count clj

(job-peer-count replica job)

leaf-tasks clj

(leaf-tasks workflow root-task)

messenger-slot-id clj

(messenger-slot-id replica job-id task-id peer-id)

peer->allocated-job clj

(peer->allocated-job allocations id)

promote-orphans clj

(promote-orphans replica group-id)

remove-peers clj

(remove-peers replica id)

Inputs: [replica :- os/Replica id :- os/PeerId]

replica->job-peers clj

(replica->job-peers replica job-id)

root-tasks clj

(root-tasks workflow leaf-task)

src-peers clj

(src-peers replica ingress-tasks job-id)

start-new-lifecycle clj

(start-new-lifecycle old new diff state scheduler-event)

Inputs: [old :- os/Replica new :- os/Replica diff state scheduler-event :- os/PeerSchedulerEvent]

start-task! clj

(start-task! lifecycle)

state-task? clj

(state-task? replica job-id task-id)

stop-lifecycle-peer-group! clj

(stop-lifecycle-peer-group! state scheduler-event)

to-graph clj

(to-graph workflow)

upstream-peers clj

(upstream-peers replica ingress-tasks job-id)