missinterpret.flows.core — io.github.missinterpret/flows 1.0.7

connect-node clj

(connect-node workflow node args)

Connects the sink of one flow as the source of the next updating the workflow.

Note: This operates on the inverse of the convention for streams. i.e. source

flowify clj

(flowify flow-catalog arg & {:flow/keys [expand] :or {expand false} :as opts})

Converts the argument into an appropriate flow.

• flow or workflow: pass-through
• fn: returns a fn-flow (optionally uses result pipelining via expand-flow)
• else: lookup flow in catalog

fn-flow clj

(fn-flow fn-arg & {:flow/keys [expand id] :or {expand false id nil} :as opts})

Returns a flow map for a fn which wraps its execution to conform to the stream model.

interceptor-order clj

(interceptor-order flow-catalog
                   definition
                   &
                   {:keys [expand] :or {expand false} :as opts})

invoke clj

(invoke {:workflow/keys [expand repeat-n put-timeout take-timeout sink source
                         log-fn]
         :or {expand false repeat-n nil}
         :as workflow}
        runtime-arg)

Invokes the workflow operating on its streams to execute as a synchronous operation returning a vector of the results.

Notes

The operation is in two phases populating the sink with the passed argument using the workflow options and the take phase which populates the output vector.

Unless specified by return-n, the operation will return all pending values from the workflow source.

Options

• expand When true run will put-all! when the runtime argument is a seq
• repeat-n n copies of the passed argument is added before the take phase.
• put-timeout Will wait X milliseconds before throwing an exception during put operations.
• take-timeout Will wait X milliseconds before throwing an exception during take operations.

linear-order clj

(linear-order
  flow-catalog
  definition
  &
  {:keys [expand omit-leave] :or {expand false omit-leave false} :as opts})

lookup-flow clj

(lookup-flow catalog id & {:keys [throw-missing] :or {throw-missing false}})

Looks up a flow from the catalog by its :flow/id

validate-topology clj

(validate-topology flow-catalog definition)

Checks that the entries of the workflow definition to be processed by workflow-factory is a seq, isn't empty, has a recognized type, any dependent workflow is loaded, and exists in the flow catalog when defined by id.