Struct DurableOperation 

pub struct DurableOperation { /* private fields */ }

A durable operation with inspection and interaction methods.

Wraps an SDK Operation and provides type-specific inspection methods and callback interaction capabilities for testing.

Examples

use durable_execution_sdk_testing::DurableOperation;

// Get operation from test runner
let op = runner.get_operation("my-step").unwrap();

// Inspect basic properties
println!("ID: {}", op.get_id());
println!("Type: {}", op.get_type());
println!("Status: {}", op.get_status());

// Get type-specific details
if op.get_type() == OperationType::Step {
    let details = op.get_step_details::<String>().unwrap();
    println!("Result: {:?}", details.result);
}

Implementations

impl DurableOperation

pub fn new(operation: Operation) -> Self

Creates a new DurableOperation wrapping the given SDK operation.

pub fn with_callback_sender( operation: Operation, callback_sender: Arc<dyn CallbackSender>, ) -> Self

Creates a new DurableOperation with a callback sender.

pub fn with_status_watcher( operation: Operation, status_watcher: Receiver<OperationStatus>, ) -> Self

Creates a new DurableOperation with a status watcher.

pub fn with_all( operation: Operation, callback_sender: Option<Arc<dyn CallbackSender>>, status_watcher: Option<Receiver<OperationStatus>>, ) -> Self

Creates a new DurableOperation with both callback sender and status watcher.

pub fn get_id(&self) -> &str

Gets the operation ID.

Returns

The unique identifier for this operation.

pub fn get_parent_id(&self) -> Option<&str>

Gets the parent operation ID.

Returns

The parent operation ID if this is a nested operation, None otherwise.

pub fn get_name(&self) -> Option<&str>

Gets the operation name.

Returns

The human-readable name if set, None otherwise.

pub fn get_type(&self) -> OperationType

Gets the operation type.

Returns

The type of operation (Step, Wait, Callback, Invoke, Context, Execution).

pub fn get_status(&self) -> OperationStatus

Gets the operation status.

Returns

The current status of the operation.

pub fn get_start_timestamp(&self) -> Option<DateTime<Utc>>

Gets the start timestamp.

Returns

The start timestamp as a DateTime if available.

pub fn get_end_timestamp(&self) -> Option<DateTime<Utc>>

Gets the end timestamp.

Returns

The end timestamp as a DateTime if available.

pub fn get_operation_data(&self) -> &Operation

Gets the raw operation data.

Returns

A reference to the underlying SDK Operation.

pub fn is_callback(&self) -> bool

Checks if this is a callback operation.

Returns

True if this operation is of type Callback.

pub fn is_completed(&self) -> bool

Checks if the operation has completed.

Returns

True if the operation status is terminal (Succeeded, Failed, Cancelled, TimedOut, Stopped).

pub fn is_succeeded(&self) -> bool

Checks if the operation succeeded.

Returns

True if the operation status is Succeeded.

pub fn is_failed(&self) -> bool

Checks if the operation failed.

Returns

True if the operation status is Failed, Cancelled, or TimedOut.

pub fn with_operations(self, all_operations: Arc<Vec<Operation>>) -> Self

Sets the shared reference to all operations for child enumeration.

impl DurableOperation

pub fn get_child_operations(&self) -> Vec<DurableOperation>

Returns all child operations nested under this operation.

Child operations are those whose parent_id matches this operation’s id. The returned operations are ordered by their position in the operations list.

Returns

A vector of DurableOperation instances representing child operations. Returns an empty vector if no children exist or if the operations list is not available.

impl DurableOperation

pub fn get_step_details<T: DeserializeOwned>( &self, ) -> Result<StepDetails<T>, TestError>

Gets step-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(StepDetails<T>) - The step details if this is a Step operation
• Err(TestError) - Error if this is not a Step operation

pub fn get_wait_details(&self) -> Result<WaitDetails, TestError>

Gets wait-specific details.

Returns

• Ok(WaitDetails) - The wait details if this is a Wait operation
• Err(TestError) - Error if this is not a Wait operation

pub fn get_callback_details<T: DeserializeOwned>( &self, ) -> Result<CallbackDetails<T>, TestError>

Gets callback-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(CallbackDetails<T>) - The callback details if this is a Callback operation
• Err(TestError) - Error if this is not a Callback operation

pub fn get_invoke_details<T: DeserializeOwned>( &self, ) -> Result<InvokeDetails<T>, TestError>

Gets invoke-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(InvokeDetails<T>) - The invoke details if this is an Invoke operation
• Err(TestError) - Error if this is not an Invoke operation

pub fn get_context_details<T: DeserializeOwned>( &self, ) -> Result<ContextDetails<T>, TestError>

Gets context-specific details.

Type Parameters

• T - The type to deserialize the result into

Returns

• Ok(ContextDetails<T>) - The context details if this is a Context operation
• Err(TestError) - Error if this is not a Context operation

impl DurableOperation

pub async fn send_callback_success(&self, result: &str) -> Result<(), TestError>

Sends a success response for a callback operation.

Arguments

• result - The result value to send as a JSON string

Returns

• Ok(()) - If the callback response was sent successfully
• Err(TestError) - If this is not a callback operation or sending failed

pub async fn send_callback_failure( &self, error: &TestResultError, ) -> Result<(), TestError>

Sends a failure response for a callback operation.

Arguments

• error - The error information to send

Returns

• Ok(()) - If the callback response was sent successfully
• Err(TestError) - If this is not a callback operation or sending failed

pub async fn send_callback_heartbeat(&self) -> Result<(), TestError>

Sends a heartbeat for a callback operation.

Returns

• Ok(()) - If the heartbeat was sent successfully
• Err(TestError) - If this is not a callback operation or sending failed

impl DurableOperation

pub async fn wait_for_data( &self, target_status: WaitingOperationStatus, ) -> Result<&Self, TestError>

Waits for the operation to reach a specific status.

Arguments

• target_status - The status to wait for

Returns

• Ok(&Self) - Reference to self when the target status is reached
• Err(TestError) - If the execution completes before reaching the target status

Trait Implementations

impl Clone for DurableOperation

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DurableOperation

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

Formats the value using the given formatter.