Struct VisualStreamDesigner 

pub struct VisualStreamDesigner { /* private fields */ }

Visual designer main struct

Implementations

impl VisualStreamDesigner

pub fn new(config: VisualDesignerConfig) -> Self

Create a new visual stream designer

pub async fn create_pipeline( &self, name: String, description: Option<String>, ) -> Result<String>

Create a new empty pipeline

pub async fn add_node( &self, pipeline_id: &str, name: String, node_type: NodeType, position: Position, ) -> Result<String>

Add a node to the pipeline

pub async fn add_edge( &self, pipeline_id: &str, source_node_id: String, source_port_id: String, target_node_id: String, target_port_id: String, ) -> Result<String>

Add an edge connecting two nodes

pub async fn validate_pipeline( &self, pipeline_id: &str, ) -> Result<ValidationResult>

Validate a pipeline

pub async fn optimize_pipeline( &self, pipeline_id: &str, ) -> Result<OptimizationResult>

Optimize a pipeline

pub async fn export_pipeline( &self, pipeline_id: &str, format: ExportFormat, ) -> Result<String>

Export pipeline to specified format

pub async fn import_pipeline( &self, data: &str, format: ExportFormat, ) -> Result<String>

Import pipeline from string

pub async fn create_debugger( &self, pipeline_id: &str, config: DebuggerConfig, ) -> Result<String>

Create a debugger for a pipeline

pub async fn add_breakpoint( &self, debugger_id: &str, node_id: String, condition: Option<String>, ) -> Result<String>

Add a breakpoint to a debugger

pub async fn get_debugger_state( &self, debugger_id: &str, ) -> Result<DebuggerState>

Get debugger state

pub async fn get_event_history( &self, debugger_id: &str, limit: Option<usize>, ) -> Result<Vec<DebugEvent>>

Get event history from debugger

pub async fn list_pipelines(&self) -> Vec<PipelineInfo>

List all pipelines

pub async fn get_pipeline(&self, pipeline_id: &str) -> Result<VisualPipeline>

Get pipeline details

pub async fn delete_pipeline(&self, pipeline_id: &str) -> Result<()>

Delete a pipeline