Liking cljdoc? Tell your friends :D
Clojure only.

onyx.log.commands.common

allocations->peersclj

(allocations->peers allocations)
source

build-stop-task-fnclj

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

grouped-task?clj

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

input-task?clj

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

job->peersclj

(job->peers replica)
source

job-allocations->peer-idsclj

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

job-peer-countclj

(job-peer-count replica job)
source

leaf-tasksclj

(leaf-tasks workflow root-task)
source

messenger-slot-idclj

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

peer->allocated-jobclj

(peer->allocated-job allocations id)
source

promote-orphansclj

(promote-orphans replica group-id)
source

remove-peersclj

(remove-peers replica id)

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

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

replica->job-peersclj

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

root-tasksclj

(root-tasks workflow leaf-task)
source

src-peersclj

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

start-new-lifecycleclj

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

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

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

start-task!clj

(start-task! lifecycle)
source

state-task?clj

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

stop-lifecycle-peer-group!clj

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

to-graphclj

(to-graph workflow)
source

upstream-peersclj

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

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close