Struct ThreadService 

pub struct ThreadService { /* private fields */ }

Cloneable host for exactly one root run. All adapters in that run must share this instance, so independent callers cannot reset the admission counters.

Implementations

impl ThreadService

pub async fn attach( kernel: Arc<CapturedThreadKernel>, events: Arc<dyn RuntimeEventSink>, grant: Option<RootDelegationGrant>, ) -> Result<Self>

Attach to a newly committed root. Existing child trees require recovery, not fresh zeroed counters. Call once, before exposing root agent tools.

Errors

Rejects a second attachment, stale roots, existing children, mismatched authority or an unavailable/exceeded captured root budget. Root policy, original artifact, persistence and cancellation come only from the manager’s capture, never from adapter-supplied replacements.

pub async fn root_controls(&self) -> Result<Arc<AgentToolContext>>

Obtain root-bound controls after attachment, for the root kernel only.

pub async fn shutdown(&self) -> Result<()>

Close admission, cancel the tree, and join every accepted host job. The root adapter still owns its root record’s terminal transition.

Errors

Reports a panicked job or unresolved child write after attempting all cleanup. No uncertain mutation is retried. A cancelled shutdown waiter leaves join handles in this service for a later caller to finish joining.

pub async fn reconcile(&self, thread_id: &str) -> Result<AgentThread>

Recover only an exact committed write. A start recovered after its failed request is closed as failed/cancelled, never replayed. Missing or different reads preserve uncertainty and do not release lifetime quota.

pub async fn take_root_messages(&self) -> Result<Vec<InterAgentMessage>>

Drain root messages at a root-kernel boundary. Identity stays in the envelope; the kernel appends bodies without identity prompt prefixes.

pub async fn refresh_root(&self) -> Result<AgentThread>

Publish a root transition only after the root adapter has committed it. A completed root closes descendant work; its old authority cannot be carried into another root turn through an already-captured tool context.

Trait Implementations

impl AgentThreadHost for ThreadService

fn spawn<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, request: AgentSpawnRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentThread>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn spawn_remote<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, request: RemoteAgentSpawnRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentThread>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn send_message<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, request: SendAgentMessageRequest, ) -> Pin<Box<dyn Future<Output = Result<InterAgentMessage>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load_thread<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, thread_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentThread>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn list_threads<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, ) -> Pin<Box<dyn Future<Output = Result<Vec<AgentThread>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn subscribe_thread<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, thread_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<AgentHandle>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn subscribe_first_turn<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, thread_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<AgentHandle>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Subscribe to the first invocation’s retained result, not latest state. Hosts without a receipt cannot substitute a later resumed turn.

fn interrupt<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, scope: &'life1 AgentControlScope, thread_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<AgentInterruptReceipt>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

impl Clone for ThreadService

fn clone(&self) -> ThreadService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadService

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

Formats the value using the given formatter.