Struct Executor 

pub struct Executor { /* private fields */ }

Executes a plan or individual actions.

Consumers drive execution by calling Executor::execute_operation for each operation.

Implementations

impl Executor

pub fn new( storage_a: Arc<dyn Storage>, storage_b: Arc<dyn Storage>, status: Arc<StatusDatabase>, ) -> Executor

Create a new instance with default concurrency.

Default concurrency is 4. Use with_concurrency to customize it.

pub fn with_concurrency(self, concurrency: usize) -> Self

Set the concurrency level for operation execution.

Controls how many operations can execute in parallel. Higher values may improve performance but increase resource usage.

pub async fn execute_operation( &self, operation: Operation, ) -> Result<Result<(), SyncError>, StatusError>

Execute a single operation.

Dispatches to the appropriate handler based on operation type.

Errors

• Returns Err(_) for a fatal error interacting with the status database. The caller must stop execution.
• Returns Ok(Err(_)) for a non-fatal error. The caller may continue with further operations.

pub fn execute_item_status_action( &self, action: StatusAction, mapping_uid: MappingUid, ) -> Result<(), StatusError>

Execute a status-only action (no storage operations).

This should only be used after manually updating an item in both storages, typically, after a manual conflict resolution.

Errors

Returns Err(_) for a fatal error interacting with the status database.