Struct VisualPipelineBuilder 

pub struct VisualPipelineBuilder {
    pub workflow: WorkflowDefinition,
    pub component_positions: HashMap<String, Position>,
    pub canvas_config: CanvasConfig,
    pub validation_state: ValidationState,
    pub history: Vec<WorkflowSnapshot>,
    pub history_index: usize,
}

Visual pipeline builder for creating workflows graphically

Fields

workflow: WorkflowDefinition

Current workflow being built

component_positions: HashMap<String, Position>

Component positioning information

canvas_config: CanvasConfig

Canvas configuration

validation_state: ValidationState

Validation state

history: Vec<WorkflowSnapshot>

Undo/redo history

history_index: usize

Current history index

Implementations

impl VisualPipelineBuilder

pub fn new() -> Self

Create a new visual pipeline builder

pub fn add_step(&mut self, step: StepDefinition) -> SklResult<()>

Add a step to the workflow

pub fn remove_step(&mut self, step_id: &str) -> SklResult<()>

Remove a step from the workflow

pub fn add_connection(&mut self, connection: Connection) -> SklResult<()>

Add a connection between steps

pub fn remove_connection( &mut self, from_step: &str, from_output: &str, to_step: &str, to_input: &str, ) -> SklResult<()>

Remove a connection

pub fn move_component( &mut self, step_id: &str, position: Position, ) -> SklResult<()>

Move a component to a new position

pub fn update_step_parameters( &mut self, step_id: &str, parameters: BTreeMap<String, ParameterValue>, ) -> SklResult<()>

Update step parameters

pub fn validate(&mut self) -> &ValidationState

Validate the current workflow and update the validation state.

This method performs a comprehensive validation pass, updating [self.validation_state] with the latest errors and warnings. It does not short-circuit the caller when issues are detected; instead, callers are expected to inspect the returned ValidationState and decide whether to proceed.

pub fn snap_to_grid(&self, position: Position) -> Position

Snap position to grid

pub fn undo(&mut self) -> SklResult<()>

Undo last action

pub fn redo(&mut self) -> SklResult<()>

Redo last undone action

pub fn get_workflow(&self) -> &WorkflowDefinition

Get current workflow

pub fn get_component_positions(&self) -> &HashMap<String, Position>

Get component positions

pub fn get_validation_state(&self) -> &ValidationState

Get validation state

pub fn clear(&mut self)

Clear the workflow

pub fn set_canvas_config(&mut self, config: CanvasConfig)

Set canvas configuration

pub fn get_canvas_config(&self) -> &CanvasConfig

Get canvas configuration

Trait Implementations

impl Clone for VisualPipelineBuilder

fn clone(&self) -> VisualPipelineBuilder

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for VisualPipelineBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for VisualPipelineBuilder

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for VisualPipelineBuilder

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for VisualPipelineBuilder

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.