Struct RedisRunInfoStore 

pub struct RedisRunInfoStore { /* private fields */ }

Redis implementation of the RunInfoStore trait.

Implementations

impl RedisRunInfoStore

pub fn new(client: RedisClient) -> Self

Create a new Redis run info store with the given client.

Trait Implementations

impl Clone for RedisRunInfoStore

fn clone(&self) -> RedisRunInfoStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RunInfoStore for RedisRunInfoStore

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

where Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update the output for a workflow run.