Liking cljdoc? Tell your friends :D

ablauf.job.manifold

An execution engine for warp jobs on manifold. To perform parallel actions with manifold.

Execution is represented as a stream on which results are produced.

The stream is closed when execution is finished. Each execution step is store with the help of a ablauf.job.store/JobStore implementation that needs to be supplied.

This namespace makes no assumption on how to actually perform side-effects, consumers of runner need to extend the dispatch-action multimethod to perform those.

An execution engine for warp jobs on manifold.
To perform parallel actions with manifold.

Execution is represented as a stream on which results
are produced.

The stream is closed when execution is finished.
Each execution step is store with the help of a
`ablauf.job.store/JobStore` implementation that
needs to be supplied.

This namespace makes no assumption on how to actually
perform side-effects, consumers of `runner` need to
extend the `dispatch-action` multimethod to perform those.
raw docstring

dispatch-actioncljmultimethod

Dumb action handler, should live in its own namespace and be provided to the runner instead.

Methods should be installed by callers of runner since this namespace does not know what side effects may be performed.

All methods are expected to yield manifold deferred.

Dumb action handler, should live in its own namespace
and be provided to the runner instead.

Methods should be installed by callers of `runner` since
this namespace does not know what side effects may be performed.

All methods are expected to yield manifold deferred.
sourceraw docstring

fail!clj

(fail! input clock dispatch result)

Push a failure value back on the restarter

Push a failure value back on the restarter
sourceraw docstring

redispatcherclj

(redispatcher input store id result)

Once dispatchs have been determined by job/restart, dispatch actions with callbacks into the restarter.

Once dispatchs have been determined by `job/restart`, dispatch
actions with callbacks into the restarter.
sourceraw docstring

restart-transducerclj

(restart-transducer job)

A transducer which yields all intermediate reduced values of job/restart

A transducer which yields all intermediate
reduced values of `job/restart`
sourceraw docstring

runnerclj

(runner store ast)
(runner store ast {:keys [id context buffer runtime] :or {buffer 10}})

Create a stream which listens for input results and figures out next dispatchs to send

Create a stream which listens for input results and figures
out next dispatchs to send
sourceraw docstring

success!clj

(success! input clock dispatch result)

Push a success value back on the restarter

Push a success value back on the restarter
sourceraw docstring

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

× close