Struct LocalStateAdapter 

pub struct LocalStateAdapter { /* private fields */ }

Local state adapter (stores state in local files)

Implementations

impl LocalStateAdapter

pub fn new() -> Self

Create a new local state adapter

pub fn with_base_dir<P: AsRef<Path>>(base_dir: P) -> Self

Create a new local state adapter with a custom base directory

Trait Implementations

impl Default for LocalStateAdapter

fn default() -> Self

Returns the “default value” for a type.

impl StateAdapter for LocalStateAdapter

fn save_workflow_run<'life0, 'life1, 'async_trait>( &'life0 mut self, workflow_run: &'life1 WorkflowRun, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a workflow run

fn apply_workflow_run_diff<'life0, 'life1, 'async_trait>( &'life0 mut self, diff: &'life1 WorkflowRunDiff, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Apply a diff to a workflow run

fn get_workflow_run<'life0, 'async_trait>( &'life0 self, workflow_run_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<WorkflowRun>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a workflow run

fn list_workflow_runs<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkflowRun>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List workflow runs

fn save_task<'life0, 'life1, 'async_trait>( &'life0 mut self, task: &'life1 Task, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a task

fn get_task<'life0, 'async_trait>( &'life0 self, task_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Task>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a task

fn get_tasks<'life0, 'async_trait>( &'life0 self, workflow_run_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Task>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all tasks for a workflow run

fn update_state<'life0, 'async_trait>( &'life0 mut self, workflow_run_id: Uuid, state: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update workflow state

fn apply_task_diff<'life0, 'life1, 'async_trait>( &'life0 mut self, diff: &'life1 TaskDiff, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Apply a diff to a task

fn apply_state_diff<'life0, 'life1, 'async_trait>( &'life0 mut self, diff: &'life1 StateDiff, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Apply a diff to workflow state

fn get_state<'life0, 'async_trait>( &'life0 self, workflow_run_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get workflow state