Struct Control 

pub struct Control { /* private fields */ }

Cooperative lifecycle handle shared across an invocation.

Cloning a Control shares the same cancellation and limit state. Cancellation is cooperative: RuntimeInvocation::emit checks Control::is_cancelled before invoking the closure and before calling AgentRuntime::run; the underlying runtime does not yet support hard cancellation. Timeout and concurrency limit are enforced by event listeners spawned through RuntimeInvocation::on.

Type-erased data

Control also carries an extension map for injecting arbitrary typed data into handlers (similar to actix-web::web::Data<T>). Use Control::set_data and Control::data to store and retrieve Arc<T> values keyed by TypeId.

Implementations

impl Control

pub fn new() -> Self

Creates a fresh control handle: not cancelled, no timeout, no limit.

pub fn cancel(&self)

Marks this invocation as cancelled.

pub fn is_cancelled(&self) -> bool

Returns true once cancel has been called on any clone.

pub fn set_timeout(&self, timeout: Duration)

Sets a provider/runtime call timeout hint.

pub fn timeout(&self) -> Option<Duration>

Returns the configured timeout hint, if any.

pub fn set_concurrency_limit(&self, limit: usize)

Sets a concurrency limit hint.

pub fn concurrency_limit(&self) -> Option<usize>

Returns the configured concurrency limit hint, if any.

pub fn set_data<T: Send + Sync + 'static>(&self, val: T)

Stores a type-erased value in the extension map.

Values are keyed by TypeId; storing a second value of the same type overwrites the first.

pub fn data<T: Send + Sync + 'static>(&self) -> Option<Arc<T>>

Retrieves a previously stored value by type.

Returns None when no value of type T has been stored.

Trait Implementations

impl Clone for Control

fn clone(&self) -> Control

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Control

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

Formats the value using the given formatter.

impl Default for Control

fn default() -> Self

Returns the “default value” for a type.