skainet-pipeline/sk.ainet.pipeline

Package-level declarations

Types

class ConditionalEdge<I>(val from: String, val router: (I) -> String)

A conditional edge that routes data based on runtime conditions.

data class Edge(val from: String, val to: String)

A directed edge connecting two nodes in a pipeline graph.

class FunctionNode<I, O>(val name: String, block: (I) -> O) : Node<I, O>

A node that wraps a function.

interface Node<I, O>

A processing node in a pipeline graph.

value class NodeRef<T>(val name: String)

Reference to a node, used for chaining in the DSL.

A type-safe processing pipeline represented as a directed graph.

Builder for constructing pipelines using a DSL.

annotation class PipelineDsl

DSL marker for pipeline builders.

class PipelineNode<I, O>(val name: String, pipeline: Pipeline<I, O>) : Node<I, O>

A node that wraps another pipeline, enabling composition.

Creates a new pipeline using the DSL.