Struct ExecutionStore 

pub struct ExecutionStore { /* private fields */ }

Execution storage layer

Implementations

impl ExecutionStore

pub fn new(pool: DatabasePool) -> Self

Create a new execution store

pub async fn create(&self, ctx: &ExecutionContext) -> Result<Uuid>

Create a new execution record

pub async fn batch_create(&self, contexts: &[ExecutionContext]) -> Result<u64>

Batch create multiple execution records

This is more efficient than calling create() multiple times as it uses a single database transaction.

Returns the number of executions created.

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

Get an execution by ID

pub async fn list(&self) -> Result<Vec<(Uuid, ExecutionContext)>>

List all executions

pub async fn list_by_workflow( &self, workflow_id: &WorkflowId, ) -> Result<Vec<(Uuid, ExecutionContext)>>

List executions for a specific workflow

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

List executions with pagination

pub async fn update(&self, id: &Uuid, ctx: &ExecutionContext) -> Result<bool>

Update an execution

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

Delete an execution

pub async fn count_by_state(&self, state: &str) -> Result<i64>

Count executions by state

pub async fn get_active(&self) -> Result<Vec<(Uuid, ExecutionContext)>>

Get active executions (Running or Paused)

pub async fn delete_by_workflow(&self, workflow_id: &WorkflowId) -> Result<u64>

Delete all executions for a specific workflow Returns the number of executions deleted

pub async fn archive_completed(&self, before: DateTime<Utc>) -> Result<u64>

Archive completed executions older than the specified date Returns the number of executions archived (deleted)

Trait Implementations

impl Clone for ExecutionStore

fn clone(&self) -> ExecutionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.