Struct CompensationRegistry 

pub struct CompensationRegistry { /* private fields */ }

Registry for tracking compensation actions for workflow tasks.

CompensationRegistry maintains a mapping from task IDs to their corresponding compensation actions. During rollback, the registry is consulted to find and execute compensations in reverse order.

Implementations

impl CompensationRegistry

pub fn new() -> Self

Creates a new empty compensation registry.

pub fn register(&mut self, task_id: TaskId, compensation: ToolCompensation)

Registers a compensation action for a task.

Arguments

• task_id - The task ID to register compensation for
• compensation - The compensation action to register

Example

registry.register(
    TaskId::new("task-1"),
    ToolCompensation::file_compensation("/tmp/output.txt")
);

pub fn get(&self, task_id: &TaskId) -> Option<&ToolCompensation>

Gets the compensation action for a task.

Arguments

• task_id - The task ID to look up

Returns

• Some(&ToolCompensation) if the task has a compensation
• None if the task has no compensation registered

pub fn has_compensation(&self, task_id: &TaskId) -> bool

Checks if a task has a compensation action registered.

Arguments

• task_id - The task ID to check

Returns

• true if the task has compensation
• false if the task has no compensation

pub fn remove(&mut self, task_id: &TaskId) -> Option<ToolCompensation>

Removes a compensation action from the registry.

Typically called after successful rollback execution.

Arguments

• task_id - The task ID to remove compensation for

Returns

• Some(ToolCompensation) if the task had compensation
• None if the task had no compensation

pub fn validate_coverage(&self, task_ids: &[TaskId]) -> CompensationReport

Validates compensation coverage for a set of tasks.

Reports which tasks have compensation actions defined and which don’t.

Arguments

• task_ids - The task IDs to validate

Returns

A CompensationReport showing coverage statistics

pub fn register_file_creation( &mut self, task_id: TaskId, file_path: impl Into<String>, )

Registers a file creation compensation for a task.

Convenience method that automatically creates a file deletion compensation.

Arguments

• task_id - The task ID to register compensation for
• file_path - Path to the file that will be deleted during rollback

pub fn register_process_spawn(&mut self, task_id: TaskId, pid: u32)

Registers a process spawn compensation for a task.

Convenience method that automatically creates a process termination compensation.

Arguments

• task_id - The task ID to register compensation for
• pid - Process ID to terminate during rollback

pub fn len(&self) -> usize

Returns the number of registered compensations.

pub fn is_empty(&self) -> bool

Returns true if the registry is empty.

pub fn task_ids(&self) -> Vec<TaskId>

Returns all task IDs with registered compensations.

Trait Implementations

impl Default for CompensationRegistry

fn default() -> Self

Returns the “default value” for a type.