skainet-pipeline/sk.ainet.pipeline/PipelineBuilder

PipelineBuilder

class PipelineBuilder<I, O>(name: String)(source)

Builder for constructing pipelines using a DSL.

Constructors

PipelineBuilder

constructor(name: String)

Functions

fun build(): Pipeline<I, O>

Build the pipeline.

conditionalEdge

fun <T> conditionalEdge(from: String, router: (T) -> String)

Define a conditional edge for dynamic routing.

fun edge(from: String, to: String)

Define an explicit edge between nodes.

fun <PI, PO> embed(name: String, pipeline: Pipeline<PI, PO>): NodeRef<PO>

Embed an existing pipeline as a node.

fun entry(nodeName: String)

Define entry point (overrides auto-detection).

fun exit(nodeName: String)

Define exit point (overrides auto-detection).

fun <NI, NO> node(name: String, block: (NI) -> NO): NodeRef<NO>

Define a processing node.