Struct ProtocolServer 

pub struct ProtocolServer { /* private fields */ }

Bridge protocol server — wraps an AgentRuntime and exposes it over the NDJSON bridge protocol for external SDK consumption.

Manages sessions, tool registration via proxy tools, and event forwarding. Tool calls use a single-slot pattern: the serve loop pushes a receiver before each tool call, and ProxyTool pops it.

Implementations

impl ProtocolServer

pub fn new(runtime: AgentRuntime) -> Self

Wrap an existing AgentRuntime in a protocol server.

pub fn from_builder(builder: AgentBuilder) -> Result<Self, AgentError>

Build a protocol server from an AgentBuilder.

pub async fn register_tool( &self, name: String, description: String, parameters: Value, )

Register a tool implemented on the SDK side.

The tool’s call will block until the SDK sends a tool_result message through the bridge.

pub async fn prepare_tool_call( &self, ) -> UnboundedSender<AgentResult<Vec<Content>>>

Set up the response channel for the NEXT tool call. Returns the sender — keep it; send the result when the SDK replies.

pub async fn create_session( &self, external_id: Option<String>, ) -> (SessionId, Option<String>)

Create a new session, optionally with an external ID for reuse.

pub async fn get_or_create_session( &self, external_id: Option<String>, ) -> SessionId

Get or create a session by external_id.

If external_id is Some and a session with that id already exists, it is reused (preserving conversation history). Otherwise a new session is created and registered.

pub fn subscribe_events(&self) -> Receiver<RuntimeEvent>

Subscribe to runtime events broadcast by the agent.

pub async fn run_turn<F>( &self, sid: &SessionId, input: &str, f: F, ) -> AgentResult<RunOutcome>

where F: FnMut(RuntimeEvent) -> AgentResult<()> + Send + 'static,

Run a turn on the given session, forwarding events to the callback.

pub fn cancel(&self)

Cancel the currently running turn.

pub async fn list_tools(&self) -> Vec<ToolMetadata>

List all registered tools with their metadata, sorted by name.

Trait Implementations

impl Clone for ProtocolServer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.