Liking cljdoc? Tell your friends :D

keechma.pipelines.runtime


*pipeline-depth*cljs

source

add-to-parentcljs

(add-to-parent state {:keys [ident]})
source

add-to-queuecljs

(add-to-queue state resumable)
source

as-errorcljs

(as-error value)
source

can-start-immediately?cljs

(can-start-immediately? state resumable)
source

can-use-existing?cljs

(can-use-existing? resumable)
source

cleanup-parentscljs

(cleanup-parents {:keys [state*] :as runtime} instance)
source

default-optscljs

source

default-transactorcljs

(default-transactor transaction)
source

deregister-instancecljs

(deregister-instance state resumable)
source

enqueue-resumablecljs

(enqueue-resumable {:keys [state*] :as runtime} resumable props)
source

error?cljs

(error? value)
source

executecljs

(execute runtime context ident action value error get-interpreter-state)
source

finish-resumablecljs

(finish-resumable {:keys [state*] :as runtime}
                  {:keys [ident] :as resumable}
                  result)
source

fn->pipeline-stepcljs

(fn->pipeline-step pipeline-fn)
source

get-cancel-root-identcljs

(get-cancel-root-ident state ident)
source

get-existingcljs

(get-existing state resumable)
source

get-ident-and-descendant-identscljs

(get-ident-and-descendant-idents state ident)
(get-ident-and-descendant-idents state ident descendants)
source

get-pipeline-instancecljs

(get-pipeline-instance state ident)
source

get-queuecljs

(get-queue state queue-name)
source

get-queue-configcljs

(get-queue-config state queue-name)
source

get-queue-queuecljs

(get-queue-queue state queue-name)
source

get-queued-idents-to-cancelcljs

(get-queued-idents-to-cancel state queue-name)
source

get-queued-idents-to-startcljs

(get-queued-idents-to-start state queue-name)
source

get-resumable-queue-namecljs

(get-resumable-queue-name resumable)
source

has-pipeline?cljs

(has-pipeline? {:keys [state*]} pipeline-name)
source

in-pipeline?cljs

(in-pipeline?)
source

interpreter-state->resumablecljs

(interpreter-state->resumable stack)
(interpreter-state->resumable stack use-fresh-idents)
source

invoke-resumablecljs

(invoke-resumable runtime
                  {:keys [ident args] :as resumable}
                  {:keys [parent] :as pipeline-opts})
source

IPipelinecljsprotocol

->resumablecljs

(->resumable this pipeline-name value)
source

IPipelineInstancecljsprotocol

get-argscljs

(get-args this)

get-identcljs

(get-ident this)
source

IPipelineRuntimecljsprotocol

on-cancelcljs

(on-cancel this promise deferred-result)

wait-allcljs

(wait-all this idents)

get-pipeline-instance*cljs

(get-pipeline-instance* this ident)

cancel-allcljs

(cancel-all this idents)

stop!cljs

(stop! this)

get-activecljs

(get-active this)

report-errorcljs

(report-error this error)

transactcljs

(transact this transact-fn)

get-state*cljs

(get-state* this)

invokecljs

(invoke this pipeline)
(invoke this pipeline args)
(invoke this pipeline args config)

waitcljs

(wait this ident)

cancelcljs

(cancel this ident)
source

IResumablecljsprotocol

->pipelinecljs

(->pipeline this)
source

live-statescljs

source

make-identcljs

(make-ident pipeline-id)
source

make-pipelinecljs

(make-pipeline id pipeline)
source

Pipelinecljs

source

pipeline-step?cljs

(pipeline-step? value)
source

pipeline?cljs

(pipeline? val)
source

PipelineRuntimecljs

source

process-pipelinecljs

(process-pipeline [pipeline-name pipeline])
source

process-resumablecljs

(process-resumable {:keys [state*] :as runtime} resumable props)
source

promise->chancljs

(promise->chan promise)
source

queue-assoc-lastcljs

(queue-assoc-last state resumable result)
source

queue-assoc-last-errorcljs

(queue-assoc-last-error state resumable result)
source

queue-assoc-last-resultcljs

(queue-assoc-last-result state resumable result)
source

real-valuecljs

(real-value value prev-value)
source

register-instancecljs

(register-instance state resumable props)
(register-instance state resumable props instance-state)
source

remove-from-parentcljs

(remove-from-parent state {:keys [ident]})
source

remove-from-queuecljs

(remove-from-queue state resumable)
source

Resumablecljs

source

resumable-with-resumed-tailcljs

(resumable-with-resumed-tail runtime resumable)
source

resumable?cljs

(resumable? val)
source

run-sync-blockcljs

(run-sync-block runtime context resumable props)
source

run-sync-block-until-no-resumable-statecljs

(run-sync-block-until-no-resumable-state runtime context resumable props)
source

running-statescljs

source

start!cljs

(start! context)
(start! context pipelines)
(start! context pipelines opts)
source

start-interpretercljs

(start-interpreter runtime context resumable props)
source

start-next-in-queuecljs

(start-next-in-queue {:keys [state*] :as runtime} queue-name)
source

start-resumablecljs

(start-resumable {:keys [state* context] :as runtime}
                 {:keys [ident args] :as resumable})
source

throw-if-queues-not-matchingcljs

(throw-if-queues-not-matching state resumable)
source

update-instance-statecljs

(update-instance-state state resumable instance-state)
source

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

× close