Struct OperationRegistry 

pub struct OperationRegistry { /* private fields */ }

Registry of cancelled operation IDs and optional progress snapshots.

Callers can cancel an in-flight operation by registering its ID here before or during execution. SqlEngine::execute_with_operation_id checks this registry at the start of execution.

Implementations

impl OperationRegistry

pub fn new() -> Self

Create a new, empty operation registry.

pub fn cancel(&self, operation_id: u64)

Cancel an operation by ID. Subsequent execute_with_operation_id calls with this ID will return SqlError::OperationCancelled.

pub fn is_cancelled(&self, operation_id: u64) -> bool

Return true if operation_id has been cancelled.

pub fn remove(&self, operation_id: u64)

Remove a cancelled ID (e.g. once the operation has been cleaned up).

pub fn update_progress( &self, operation_id: u64, rows_scanned: u64, rows_emitted: u64, )

Record row-level progress for an operation.

pub fn progress(&self, operation_id: u64) -> Option<(u64, u64)>

Return the latest (rows_scanned, rows_emitted) snapshot, if any.

pub fn cancelled_ids(&self) -> Vec<u64>

Return all currently cancelled operation IDs.

Trait Implementations

impl Clone for OperationRegistry

fn clone(&self) -> OperationRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for OperationRegistry

fn default() -> OperationRegistry

Returns the “default value” for a type.