Struct FlowService 

pub struct FlowService { /* private fields */ }

Implementations

impl FlowService

pub fn new(engine: Arc<FlowEngine>) -> Self

pub fn with_factories( engine: Arc<FlowEngine>, node_factories: HashMap<String, NodeFactory>, ) -> Self

pub fn engine(&self) -> Arc<FlowEngine>

pub fn capabilities(&self) -> FlowCapabilities

pub fn node_types(&self) -> Vec<String>

pub fn node_descriptors(&self) -> Vec<NodeDescriptor>

pub fn validate(&self, definition: &Value) -> Vec<ValidationIssue>

pub async fn start_execution( &self, definition: &Value, variables: HashMap<String, Value>, ) -> Result<Uuid>

pub async fn get_execution(&self, id: Uuid) -> Result<ExecutionState>

pub async fn subscribe(&self, id: Uuid) -> Result<Receiver<FlowEvent>>

pub async fn pause_execution(&self, id: Uuid) -> Result<ExecutionState>

pub async fn resume_execution(&self, id: Uuid) -> Result<ExecutionState>

pub async fn terminate_execution(&self, id: Uuid) -> Result<()>

pub async fn get_context(&self, id: Uuid) -> Result<HashMap<String, Value>>

pub async fn set_context_entry( &self, id: Uuid, key: String, value: Value, ) -> Result<()>

pub async fn delete_context_entry(&self, id: Uuid, key: &str) -> Result<bool>

pub async fn run_named_flow( &self, name: &str, variables: HashMap<String, Value>, ) -> Result<Uuid>

pub fn register_node_type( &self, factory_name: &str, descriptor: Option<NodeDescriptor>, ) -> Result<(String, bool)>

pub fn unregister_node_type(&self, node_type: &str) -> Result<bool>

Trait Implementations

impl Clone for FlowService

fn clone(&self) -> FlowService

Returns a duplicate of the value.

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

Performs copy-assignment from source.