Struct AgentProtocolHarness 

pub struct AgentProtocolHarness { /* private fields */ }

Release-bound, multi-session kernel used by the sole native Harness.

Each entry is an AgentProtocolHost over one ordinary AgentSession. The map only retains those Code-owned sessions for conversation reuse; it never mirrors their runs or events. Miss admission is serialized so two concurrent commands cannot construct the same session twice, while work on already admitted sessions remains concurrent.

Implementations

impl AgentProtocolHarness

pub fn new( manifest: AgentReleaseManifest, agent: Arc<Agent>, workspace: impl Into<String>, ) -> Result<Self, AgentProtocolHarnessError>

Admit one release into the native Harness compatibility surface.

pub fn with_session_options(self, options: SessionOptions) -> Self

Apply common options to every Code session created by this Harness.

A caller-provided session ID is ignored. The exact protocol identity is authoritative, and auto-save is always enabled when a store is present.

pub fn with_max_sessions( self, max_sessions: usize, ) -> Result<Self, AgentProtocolHarnessError>

Override the finite retained-session limit.

pub fn manifest(&self) -> &AgentReleaseManifest

pub fn agent_release_identity(&self) -> &str

pub fn max_sessions(&self) -> usize

pub fn is_closed(&self) -> bool

pub async fn session_count(&self) -> usize

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

Route an exact command into its Code-owned conversation session.

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

Route a bounded event query into the same authoritative Code session.

pub async fn close(&self)

Stop admission and close every Code-owned session and Agent resource.

Trait Implementations

impl Debug for AgentProtocolHarness

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

Formats the value using the given formatter.