Struct CancellationController 

pub struct CancellationController { /* private fields */ }

Owner-side handle for broadcasting cancellation to running turns.

Create one CancellationController per agent and hand out CancellationHandles to the loop and tool executors. Calling interrupt bumps an internal generation counter so that every outstanding TurnCancellation checkpoint becomes cancelled.

Example

use agentkit_core::CancellationController;

let controller = CancellationController::new();
let handle = controller.handle();

// Before an interrupt the generation is 0.
assert_eq!(handle.generation(), 0);

// Signal cancellation (e.g. from a Ctrl-C handler).
controller.interrupt();
assert_eq!(handle.generation(), 1);

Implementations

impl CancellationController

pub fn new() -> Self

Creates a new controller with generation starting at 0.

pub fn handle(&self) -> CancellationHandle

Returns a cloneable CancellationHandle that shares state with this controller.

pub fn interrupt(&self) -> u64

Broadcasts a cancellation by incrementing the generation counter.

Returns the new generation value. All TurnCancellation checkpoints created before this call will report themselves as cancelled.

Trait Implementations

impl Clone for CancellationController

fn clone(&self) -> CancellationController

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CancellationController

fn default() -> CancellationController

Returns the “default value” for a type.