Struct CancelToken 

pub struct CancelToken<'a> { /* private fields */ }

v4.5 cooperative cancellation token. A long-running SELECT / UPDATE / DELETE checks is_cancelled at row-loop checkpoints and bails with EngineError::Cancelled. The host (spg-server) creates an AtomicBool per query, spawns a watchdog thread that sets it after SPG_QUERY_TIMEOUT_MS, and passes it via execute_with_cancel / execute_readonly_with_cancel.

CancelToken::none() is a no-op — used by the legacy execute and execute_readonly entry points so existing callers don’t change.

Implementations

impl<'a> CancelToken<'a>

pub const fn none() -> Self

pub const fn from_flag(f: &'a AtomicBool) -> Self

pub fn is_cancelled(self) -> bool

pub fn check(self) -> Result<(), EngineError>

Returns Err(Cancelled) if the token has been tripped. Used at row-loop checkpoints to bail cooperatively without scattering raw is_cancelled checks across the executor.

Trait Implementations

impl<'a> Clone for CancelToken<'a>

fn clone(&self) -> CancelToken<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for CancelToken<'a>

impl<'a> Debug for CancelToken<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.