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.

Requirements

• 4.4: WHEN a developer calls get_operation_by_id(id) on Test_Runner, THE Test_Runner SHALL return the operation with that unique identifier

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.

Requirements

• 4.1: WHEN a developer calls get_operation(name) on Test_Runner, THE Test_Runner SHALL return the first operation with that name

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.

Requirements

• 8.1: Returns all operations whose parent_id matches this operation’s id
• 8.2: Returns empty Vec when no children exist
• 8.3: Returned operations ordered by their position in the operations list

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

Requirements

• 5.1: WHEN a developer calls get_step_details() on a Step operation, THE Durable_Operation SHALL return attempt count, result, and error information
• 5.6: IF a developer calls a type-specific method on the wrong operation type, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 5.2: WHEN a developer calls get_wait_details() on a Wait operation, THE Durable_Operation SHALL return the wait duration and scheduled end timestamp
• 5.6: IF a developer calls a type-specific method on the wrong operation type, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 5.3: WHEN a developer calls get_callback_details() on a Callback operation, THE Durable_Operation SHALL return the callback ID, result, and error
• 5.6: IF a developer calls a type-specific method on the wrong operation type, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 5.4: WHEN a developer calls get_invoke_details() on an Invoke operation, THE Durable_Operation SHALL return the invocation result and error
• 5.6: IF a developer calls a type-specific method on the wrong operation type, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 5.5: WHEN a developer calls get_context_details() on a Context operation, THE Durable_Operation SHALL return the context result and error
• 5.6: IF a developer calls a type-specific method on the wrong operation type, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 6.1: WHEN a developer calls send_callback_success(result) on a callback operation, THE Durable_Operation SHALL send a success response to the checkpoint service
• 6.4: IF a developer calls callback methods on a non-callback operation, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 6.2: WHEN a developer calls send_callback_failure(error) on a callback operation, THE Durable_Operation SHALL send a failure response to the checkpoint service
• 6.4: IF a developer calls callback methods on a non-callback operation, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 6.3: WHEN a developer calls send_callback_heartbeat() on a callback operation, THE Durable_Operation SHALL send a heartbeat to keep the callback active
• 6.4: IF a developer calls callback methods on a non-callback operation, THEN THE Durable_Operation SHALL return an error

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

Requirements

• 10.1: WHEN a developer calls wait_for_data() on a Durable_Operation, THE Durable_Operation SHALL return a future that resolves when the operation has started
• 10.2: WHEN a developer calls wait_for_data(WaitingStatus::Completed) on a Durable_Operation, THE Durable_Operation SHALL return a future that resolves when the operation has completed
• 10.3: WHEN a developer calls wait_for_data(WaitingStatus::Submitted) on a callback operation, THE Durable_Operation SHALL return a future that resolves when the callback is ready to receive responses
• 10.4: IF the execution completes before the operation reaches the requested state, THEN THE Durable_Operation SHALL return an error

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.