CreateContext create request context (used by template).

CreatePipeline creates a core pipeline.

GetPipelineDefinition generate pipeline DAG defintion as a json.

NewDag Creates a Dag.

StateFailure denotes failure state.

StateOngoing denotes ongoing state.

StateSuccess denotes success state.

Default forwarder.

ERR_CYCLIC denotes that dag has a cycle.

ERR_DUPLICATE_EDGE denotes that a dag edge is duplicate.

ERR_DUPLICATE_VERTEX denotes that a dag edge is duplicate.

ERR_MULTIPLE_START denotes that a dag has more than one start point.

ERR_NO_VERTEX.

ERR_RECURSIVE_DEP denotes that dag has a recursive dependecy.

Context execution context and execution state.

Dag The whole dag.

Node The vertex.

DataStore for Storing Data.

EventHandler handle flow events.

Logger logs the flow logs.

StateStore for saving execution state.

Aggregator definition for the data aggregator of nodes.

Condition definition for the condition function.

ForEach definition for the foreach function.

Forwarder definition for the data forwarder of nodes.

PipelineErrorHandler the error handler OnFailure() registration on pipeline.

PipelineHandler definition for the Finally() registration on pipeline.