Struct WorkflowPersistence 

pub struct WorkflowPersistence { /* private fields */ }

Workflow persistence manager

Handles saving and loading workflow contexts to/from disk. Files are stored in JSON format under:

• ~/.matrix/workflows/ (user/global)
• .matrix/workflows/ (project-specific)

Implementations

impl WorkflowPersistence

pub fn new(project_dir: Option<&PathBuf>) -> Self

Create a new persistence manager with project context

Searches both project and user directories when loading. Saves to project directory if available, else to user directory.

pub fn new_global() -> Self

Create a persistence manager for user directory only (no project context)

pub fn with_base_path(base_path: PathBuf) -> Self

Create a persistence manager with a custom base path

Useful for testing or custom configurations.

pub fn save(&self, context: &WorkflowContext) -> Result<()>

Save a workflow context to disk

The context is serialized to JSON and stored in the save directory (project directory if available, else user directory).

Example

let persistence = WorkflowPersistence::new(Some(&project_path));
let ctx = WorkflowContext::new("my_workflow".to_string(), HashMap::new());
persistence.save(&ctx)?;

pub fn load(&self, instance_id: &str) -> Result<Option<WorkflowContext>>

Load a workflow context from disk

Searches both project and user directories. Returns Ok(None) if the instance_id does not exist.

Example

let persistence = WorkflowPersistence::new(Some(&project_path));
if let Some(ctx) = persistence.load("run-123")? {
    println!("Loaded workflow: {}", ctx.workflow_id);
}

pub fn list(&self) -> Result<Vec<WorkflowContext>>

List all saved workflow contexts from both directories

Returns a list of all persisted workflow contexts. Failed loads are logged and skipped.

Example

let persistence = WorkflowPersistence::new(Some(&project_path));
let workflows = persistence.list()?;
for ctx in workflows {
    println!("{}: {:?}", ctx.instance_id, ctx.status);
}

pub fn delete(&self, instance_id: &str) -> Result<()>

Delete a saved workflow context

Searches both directories and deletes from where it exists. Returns Ok(()) even if the file does not exist.

Example

let persistence = WorkflowPersistence::new(Some(&project_path));
persistence.delete("run-123")?;

pub fn list_by_status( &self, status: WorkflowStatus, ) -> Result<Vec<WorkflowContext>>

List workflow contexts by status

Example

let persistence = WorkflowPersistence::new(Some(&project_path));
let paused = persistence.list_by_status(WorkflowStatus::Paused)?;

pub fn save_path(&self) -> &PathBuf

Get the save path (where new workflows will be saved)

pub fn user_path(&self) -> &PathBuf

Get the user path

pub fn project_path(&self) -> Option<&PathBuf>

Get the project path (if available)

Trait Implementations

impl Default for WorkflowPersistence

fn default() -> Self

Returns the “default value” for a type.