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.
raw docstring

fail!clj

(fail! input clock dispatch result)

Push a failure value back on the restarter

Push a failure value back on the restarter
raw 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.
raw 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`
raw 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
raw docstring

success!clj

(success! input clock dispatch result)

Push a success value back on the restarter

Push a success value back on the restarter
raw docstring

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

× close