Struct AgentProtocolHost 

pub struct AgentProtocolHost { /* private fields */ }

One release- and session-bound A3S Code headless protocol host.

Cloud, Fleet, and other callers may transport commands and receipts, but this adapter is the sole mapping into Code’s run lifecycle and event store.

Implementations

impl AgentProtocolHost

pub fn new( agent_release_identity: impl Into<String>, session: Arc<AgentSession>, ) -> Result<Self, AgentProtocolHostError>

pub fn from_manifest( manifest: &AgentReleaseManifest, session: Arc<AgentSession>, ) -> Result<Self, AgentProtocolHostError>

Bind an admitted v1 release manifest to its Code session.

Capability compatibility remains an activation concern for the process host, but a manifest for another protocol can never enter this v1 host.

pub fn agent_release_identity(&self) -> &str

pub fn session(&self) -> &Arc<AgentSession>

pub async fn execute( &self, command: &AgentProtocolCommandV1, ) -> Result<AgentProtocolCommandReceiptV1, AgentProtocolHostError>

Execute, cancel, or recover one exact run and return a digest-bound receipt. Start and recovery return after Code has admitted the detached worker; progress is observed through Self::event_page.

pub async fn execute_exact_recovery( &self, request: &AgentProtocolRunRecoverExactV1, ) -> Result<AgentProtocolCommandReceiptV1, AgentProtocolExactRecoveryError>

Recover only when the locally loadable loop boundary matches the logical component of the complete portable-checkpoint descriptor.

This additive entry point leaves AgentProtocolCommandV1 and its v1 transport shape unchanged. Validation pins the immutable checkpoint in memory before workspace baseline capture and before the target Run is admitted, so a concurrently overwritten store entry cannot change what the worker resumes.

pub async fn execute_exact_recovery_from_checkpoint( &self, request: &AgentProtocolRunRecoverExactV1, checkpoint: LoopCheckpoint, ) -> Result<AgentProtocolCommandReceiptV1, AgentProtocolExactRecoveryError>

Recover from the logical value decoded from the same validated portable checkpoint as request, without first publishing split store writes.

pub async fn event_page( &self, identity: &AgentProtocolRunIdentityV1, after_event_sequence: Option<u64>, limit: usize, ) -> Result<AgentProtocolEventPageV1, AgentProtocolHostError>

Project a bounded cursor page directly from Code’s authoritative run store without introducing a second provider event model.

pub async fn event_page_for( &self, request: &AgentProtocolEventPageRequestV1, ) -> Result<AgentProtocolEventPageV1, AgentProtocolHostError>

Execute the canonical transport-facing event page query.

pub async fn change_set_for( &self, request: &AgentProtocolChangeSetRequestV1, ) -> Result<AgentProtocolChangeSetV1, AgentProtocolHostError>

Read the immutable Git-compatible patch captured for one terminal run.

Trait Implementations

impl Clone for AgentProtocolHost

fn clone(&self) -> AgentProtocolHost

Returns a duplicate of the value.

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

Performs copy-assignment from source.