Struct InMemoryMobRunStore 

pub struct InMemoryMobRunStore { /* private fields */ }

In-memory run store.

Implementations

impl InMemoryMobRunStore

pub fn new() -> Self

Trait Implementations

impl Debug for InMemoryMobRunStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryMobRunStore

fn default() -> InMemoryMobRunStore

Returns the “default value” for a type.

impl MobRunStore for InMemoryMobRunStore

fn create_run<'life0, 'async_trait>( &'life0 self, run: MobRun, ) -> Pin<Box<dyn Future<Output = Result<(), MobStoreError>> + Send + 'async_trait>>

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

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

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

fn list_runs<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, mob_id: &'life1 MobId, flow_id: Option<&'life2 FlowId>, ) -> Pin<Box<dyn Future<Output = Result<Vec<MobRun>, MobStoreError>> + Send + 'async_trait>>

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

fn cas_run_status<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, expected: MobRunStatus, next: MobRunStatus, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

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

fn cas_flow_state<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, run_id: &'life1 RunId, expected: &'life2 KernelState, next: &'life3 KernelState, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

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

fn cas_run_snapshot<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, run_id: &'life1 RunId, expected_status: MobRunStatus, expected_flow_state: &'life2 KernelState, next_status: MobRunStatus, next_flow_state: &'life3 KernelState, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

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

fn append_step_entry<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, entry: StepLedgerEntry, ) -> Pin<Box<dyn Future<Output = Result<(), MobStoreError>> + Send + 'async_trait>>

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

fn append_step_entry_if_absent<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, entry: StepLedgerEntry, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

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

fn put_step_output<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 RunId, step_id: &'life2 StepId, output: Value, ) -> Pin<Box<dyn Future<Output = Result<(), MobStoreError>> + Send + 'async_trait>>

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

fn append_failure_entry<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, entry: FailureLedgerEntry, ) -> Pin<Box<dyn Future<Output = Result<(), MobStoreError>> + Send + 'async_trait>>

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

fn upsert_loop_snapshot<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 RunId, loop_instance_id: &'life2 LoopInstanceId, snapshot: LoopSnapshot, ledger_entry: Option<LoopIterationLedgerEntry>, ) -> Pin<Box<dyn Future<Output = Result<(), MobStoreError>> + Send + 'async_trait>>

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

Upsert a loop snapshot. Creates or overwrites the entry for loop_instance_id in run.loops and optionally records a LoopIterationLedgerEntry.

fn cas_frame_state<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, run_id: &'life1 RunId, frame_id: &'life2 FrameId, expected: Option<&'life3 FrameSnapshot>, next: FrameSnapshot, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

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

CAS wrapper 1: frame state update.

fn cas_grant_node_slot<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, run_id: &'life1 RunId, expected_run_state: &'life2 KernelState, next_run_state: KernelState, frame_id: &'life3 FrameId, expected_frame: &'life4 FrameSnapshot, next_frame: FrameSnapshot, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

CAS wrapper 2: grant node slot — atomically update run flow state + frame state.

fn cas_complete_step_and_record_output<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, run_id: &'life1 RunId, frame_id: &'life2 FrameId, expected_frame: &'life3 FrameSnapshot, next_frame: FrameSnapshot, step_output_key: String, step_output: Value, loop_context: Option<(&'life4 LoopId, u64)>, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

CAS wrapper 3: complete step — update frame state and record step output.

fn cas_start_loop<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, run_id: &'life1 RunId, loop_instance_id: &'life2 LoopInstanceId, expected_run_state: &'life3 KernelState, next_run_state: KernelState, frame_id: &'life4 FrameId, expected_frame: &'life5 FrameSnapshot, next_frame: FrameSnapshot, initial_loop: LoopSnapshot, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

CAS wrapper 4: start loop — register loop + update run state + parent frame.

fn cas_loop_request_body_frame<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, run_id: &'life1 RunId, loop_instance_id: &'life2 LoopInstanceId, expected_loop: &'life3 LoopSnapshot, next_loop: LoopSnapshot, expected_run_state: &'life4 KernelState, next_run_state: KernelState, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

CAS wrapper 5: register pending body frame — loop transition + run state update.

fn cas_grant_body_frame_start<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, run_id: &'life1 RunId, loop_instance_id: &'life2 LoopInstanceId, expected_loop: &'life3 LoopSnapshot, next_loop: LoopSnapshot, frame_id: &'life4 FrameId, initial_frame: FrameSnapshot, ledger_entry: LoopIterationLedgerEntry, expected_run_state: &'life5 KernelState, next_run_state: KernelState, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

CAS wrapper 6: body frame start — loop transition + register new frame + run state update.

fn cas_complete_body_frame<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>( &'life0 self, run_id: &'life1 RunId, loop_instance_id: &'life2 LoopInstanceId, expected_loop: &'life3 LoopSnapshot, next_loop: LoopSnapshot, frame_id: &'life4 FrameId, expected_frame: &'life5 FrameSnapshot, next_frame: FrameSnapshot, expected_run_state: &'life6 KernelState, next_run_state: KernelState, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait,

CAS wrapper 7: body frame completion — terminalize frame + loop state update + run state.

fn cas_complete_loop<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>( &'life0 self, run_id: &'life1 RunId, loop_instance_id: &'life2 LoopInstanceId, expected_loop: &'life3 LoopSnapshot, next_loop: LoopSnapshot, frame_id: &'life4 FrameId, expected_frame: &'life5 FrameSnapshot, next_frame: FrameSnapshot, expected_run_state: &'life6 KernelState, next_run_state: KernelState, ) -> Pin<Box<dyn Future<Output = Result<bool, MobStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait,

CAS wrapper 8: loop completion — loop state + run state + parent frame update.