Struct OperationState 

pub struct OperationState { /* private fields */ }

Operation State: Execution logging and history

Implementations

impl OperationState

pub fn new() -> Self

Create a new empty operation state.

pub async fn generate_id(&self) -> String

Generate a new unique operation ID

pub async fn start_operation(&self, log: OperationLog) -> String

Start tracking a new operation

pub async fn complete_operation( &self, operation_id: &str, success: bool, outputs: Option<Value>, error: Option<String>, )

Complete an operation

pub async fn mark_compensated(&self, operation_id: &str)

Mark an operation as compensated

pub async fn get_active_operations(&self) -> Vec<OperationLog>

Get active operations

pub async fn get_active_operation_ids(&self) -> Vec<String>

Get active operation IDs

pub async fn get_operation(&self, operation_id: &str) -> Option<OperationLog>

Get operation by ID

pub async fn get_agent_operations(&self, agent_id: &str) -> Vec<OperationLog>

Get all operations for an agent

pub async fn add_child_operation(&self, parent_id: &str, child_id: &str)

Add child operation to parent

Trait Implementations

impl Default for OperationState

fn default() -> Self

Returns the “default value” for a type.