Struct ExecutionManager 

pub struct ExecutionManager { /* private fields */ }

Manages all execution states.

Implementations

impl ExecutionManager

pub fn new() -> Self

Create a new execution manager.

pub fn start_execution( &mut self, params: StartExecutionParams, ) -> InvocationResult

Start a new execution.

pub fn start_execution_from_request( &mut self, request: StartDurableExecutionRequest, ) -> InvocationResult

Start a new execution from a request.

pub fn start_invocation( &mut self, params: StartInvocationRequest, ) -> Result<InvocationResult, TestError>

Start an invocation for an existing execution.

pub fn complete_invocation( &mut self, request: CompleteInvocationRequest, ) -> Result<CompleteInvocationResponse, TestError>

Complete an invocation.

pub fn get_checkpoints_by_execution( &self, execution_id: &str, ) -> Option<&CheckpointManager>

Get checkpoint manager for an execution.

pub fn get_checkpoints_by_execution_mut( &mut self, execution_id: &str, ) -> Option<&mut CheckpointManager>

Get mutable checkpoint manager for an execution.

pub fn get_checkpoints_by_token( &self, token: &str, ) -> Result<Option<&CheckpointManager>, TestError>

Get checkpoint manager by checkpoint token.

pub fn get_checkpoints_by_token_mut( &mut self, token: &str, ) -> Result<Option<&mut CheckpointManager>, TestError>

Get mutable checkpoint manager by checkpoint token.

pub fn get_execution_ids(&self) -> Vec<&ExecutionId>

Get all execution IDs.

pub fn has_execution(&self, execution_id: &str) -> bool

Check if an execution exists.

pub fn remove_execution( &mut self, execution_id: &str, ) -> Option<CheckpointManager>

Remove an execution.

pub fn clear(&mut self)

Clear all executions.

Trait Implementations

impl Debug for ExecutionManager

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

Formats the value using the given formatter.

impl Default for ExecutionManager

fn default() -> ExecutionManager

Returns the “default value” for a type.