daguerreo.impl.engine — schmee/daguerreo 0.1.0

can-transition-to-ready? clj

(can-transition-to-ready? task-map-with-state task)

Cancelable clj protocol

cancel clj

(cancel this)

cas-task-state! clj

(cas-task-state! task-state
                 event-chan
                 name
                 old-run-state
                 new-run-state
                 opt-data)

check-state-transition clj

(check-state-transition event expected-old expected-new)

completed? clj

(completed? task)

counted-thread-factory clj

(counted-thread-factory)

create-impl-key-remover clj

(create-impl-key-remover deps event-out-chan event-tap)

create-retryer clj

(create-retryer deps event-tap)

create-runner clj

(create-runner deps event-tap)

create-scheduler clj

(create-scheduler deps event-tap)

create-supervisor clj

(create-supervisor deps event-tap control-chan job-state)

create-tap clj

(create-tap mult buffer-count)

create-task-map clj

(create-task-map tasks task-graph)

create-timeouter clj

(create-timeouter deps event-tap)

default-executor clj

default-opts clj

find-unscheduled-with-deps-satisfied clj

(find-unscheduled-with-deps-satisfied task-map task-state)

(find-unscheduled-with-deps-satisfied task-map task-state candidates)

get-deps clj

(get-deps task-map-with-state task)

go-loop-bcond clj macro

(go-loop-bcond bindings & body)

Inspectable clj protocol

inspect clj

(inspect this)

is-active-fn clj

(is-active-fn event-tap task-name)

n-cores clj

reify-job clj

(reify-job deps ctx event-tap control-chan)

run clj

(run tasks)

(run tasks user-opts)

run-async-with-ex-handler clj

(run-async-with-ex-handler pool f ctx is-active-fn)

run-task! clj

(run-task! executor task-id task-state ctx event-chan create-event-tap task)

running? clj

(running? task)

set-job-state! clj

(set-job-state! job-state event-chan new-state)

set-task-state! clj

(set-task-state! task-state event-chan name task-state-or-run-state)

task-state->job-state clj

this-ns clj

unscheduled? clj

(unscheduled? task)