Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

Manages workflow execution and scheduling

Implementations

impl WorkflowEngine

pub fn new() -> Self

Create a new workflow engine

pub fn start_workflow(&mut self, workflow_name: Option<String>) -> String

Start a new workflow

pub fn activate_agenda_group(&mut self, group: String)

Activate an agenda group for workflow progression

pub fn schedule_rule( &mut self, rule_name: String, delay_ms: u64, workflow_id: Option<String>, )

Schedule a rule to execute after a delay

pub fn complete_workflow(&mut self, workflow_name: String)

Complete a workflow

pub fn set_workflow_data( &mut self, workflow_id: &str, key: String, value: Value, )

Set workflow data

pub fn get_next_agenda_group(&mut self) -> Option<String>

Get the next agenda group to activate

pub fn get_ready_tasks(&mut self) -> Vec<ScheduledTask>

Get ready scheduled tasks

pub fn get_next_pending_agenda_activation(&mut self) -> Option<String>

Get the next pending agenda activation (for syncing with agenda manager)

pub fn get_workflow(&self, workflow_id: &str) -> Option<&WorkflowState>

Get workflow state by ID

pub fn get_active_workflows(&self) -> Vec<&WorkflowState>

Get all active workflows

pub fn get_workflow_stats(&self) -> WorkflowStats

Get workflow statistics

pub fn cleanup_completed_workflows(&mut self, older_than: Duration)

Clean up completed workflows older than specified duration

Trait Implementations

impl Debug for WorkflowEngine

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

Formats the value using the given formatter.

impl Default for WorkflowEngine

fn default() -> Self

Returns the “default value” for a type.