re-mote.zero.pipeline

Base ns for zeromq pipeline support

add-error

(add-error errors)

codes

(codes v)

collect

(collect hosts k uuid timeout)

Collect results from the zmq hosts blocking until all results are back or timeout end

non-reachable

(non-reachable {:keys [hosts]} up uuid)

Adding non reachable hosts

refer-zero-pipe

(refer-zero-pipe)

run-hosts

(run-hosts hs f args)(run-hosts hs f args timeout)

with-codes

(with-codes m uuid)