Struct WorkflowStore 

pub struct WorkflowStore { /* private fields */ }

Workflow storage layer

Implementations

impl WorkflowStore

pub fn new(pool: DatabasePool) -> Self

Create a new workflow store

pub async fn create(&self, workflow: &Workflow) -> Result<WorkflowId>

Create a new workflow

pub async fn get(&self, id: &WorkflowId) -> Result<Option<Workflow>>

Get a workflow by ID

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

List all workflows

pub async fn list_paginated( &self, limit: i64, offset: i64, ) -> Result<Vec<Workflow>>

List workflows with pagination

pub async fn count(&self) -> Result<i64>

Count total workflows

pub async fn update(&self, id: &WorkflowId, workflow: &Workflow) -> Result<bool>

Update a workflow

pub async fn delete(&self, id: &WorkflowId) -> Result<bool>

Delete a workflow

pub async fn search(&self, query: &str) -> Result<Vec<Workflow>>

Search workflows by name (case-insensitive)

pub async fn bulk_create( &self, workflows: &[Workflow], ) -> Result<Vec<BulkOperationResult>>

Bulk create multiple workflows Returns a list of (id, success, error_message) tuples

pub async fn bulk_delete( &self, ids: &[WorkflowId], ) -> Result<Vec<BulkOperationResult>>

Bulk delete multiple workflows by IDs Returns a list of (id, success, error_message) tuples

pub async fn bulk_export( &self, ids: Option<&[WorkflowId]>, ) -> Result<WorkflowExport>

Bulk export workflows to JSON format

pub async fn bulk_import( &self, export: &WorkflowExport, options: ImportOptions, ) -> Result<ImportResult>

Bulk import workflows from export format Returns import results with statistics

pub async fn list_by_tag(&self, tag: &str) -> Result<Vec<Workflow>>

List workflows by tag Note: tags are stored as JSON array in SQLite

pub async fn list_by_tags(&self, tags: &[String]) -> Result<Vec<Workflow>>

List workflows by multiple tags (AND logic - must have all tags)

pub async fn list_ids(&self) -> Result<Vec<WorkflowId>>

Get workflow IDs only (for lighter queries)

pub async fn exists(&self, id: &WorkflowId) -> Result<bool>

Check if a workflow exists

pub async fn get_many(&self, ids: &[WorkflowId]) -> Result<Vec<Workflow>>

Get multiple workflows by IDs

Trait Implementations

impl Clone for WorkflowStore

fn clone(&self) -> WorkflowStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.