Struct InMemoryRunInfoStore 

pub struct InMemoryRunInfoStore { /* private fields */ }

In-memory implementation of RunInfoStore for testing and local development.

Trait Implementations

impl Clone for InMemoryRunInfoStore

fn clone(&self) -> InMemoryRunInfoStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryRunInfoStore

fn default() -> InMemoryRunInfoStore

Returns the “default value” for a type.

impl RunInfoStore for InMemoryRunInfoStore

fn insert_run<'life0, 'async_trait>( &'life0 self, info: RunInfo, ) -> Pin<Box<dyn Future<Output = Result<(), RunInfoError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryRunInfoStore: 'async_trait,

Insert a new workflow run record.

fn update_status<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, status: RunStatus, ) -> Pin<Box<dyn Future<Output = Result<(), RunInfoError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryRunInfoStore: 'async_trait,

Update the status for a workflow run.

fn update_finished_at<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, finished_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), RunInfoError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryRunInfoStore: 'async_trait,

Update the finished_at timestamp for a workflow run.

fn get_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<RunInfo>, RunInfoError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryRunInfoStore: 'async_trait,

Get the run info for a workflow run.

fn list_runs<'life0, 'async_trait>( &'life0 self, filter: Option<RunStatus>, ) -> Pin<Box<dyn Future<Output = Result<Vec<RunInfo>, RunInfoError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemoryRunInfoStore: 'async_trait,

List all workflow runs, optionally filtered by status.

fn update_output<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, output: Value, ) -> Pin<Box<dyn Future<Output = Result<(), RunInfoError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryRunInfoStore: 'async_trait,

Update the output for a workflow run.