flowgraph — com.workiva/flowgraph 0.1.1

commix clj

(commix dest & {:as spec})

A *->1 spec that commixs data flow; i.e., the first source queue containing a ready item is polled for a value which is put into the destination. This is the opposite of duplicate. Accepts optional named values (along with appropriate supporting values): #{:coordinated? :priority}

deflow clj macro

(deflow graph-name args edge-specs)

(deflow graph-name args edge-specs vertex-specs)

discriminate clj

(discriminate pred result->destination & {:as spec})

A 1->* spec that simply passes data to one of a number of destinations, determined by the result of calling predicate pred on each item. result->destination is expected to be a map from result-of-pred to destination name. Accepts optional named values (along with appropriate supporting values): #{:coordinated? :priority}

duplicate clj

(duplicate dests & {:as spec})

A 1->* spec that duplicates data along every outgoing edge. Accepts optional named values (along with appropriate supporting values): #{:coordinated? :priority}

flowgraph clj

(flowgraph edge-specs)

(flowgraph graph-name edge-specs)

(flowgraph graph-name edge-specs vertex-specs)

(flowgraph graph-name edge-specs vertex-specs constructed-args)

(flowgraph graph-name edge-specs vertex-specs constructed-args num-threads)

fuse clj

(fuse dest & {:as spec})

A *->1 spec that fuses data from a multiplicity of sources: it places into the destination queue a vector containing the outputs of all input queues. Note that this does nothing until all input queues are ready to deliver an item. This means, among other things, that combination operations are always :coordinated? Accepts optional named values (along with appropriate supporting values): #{:priority}

shutdown clj

(shutdown this)

submit clj

(submit this stuff)

Returns a tessera

transform clj

(transform f dest & {:as spec})

A 1->1 spec that transforms data by passing it through the function f. Accepts optional named values (along with appropriate supporting values): #{:batching? :asynchronous? :coordinated? :collecting? :priority}