Struct ProtocolServer 

pub struct ProtocolServer { /* private fields */ }

Implementations

impl ProtocolServer

pub fn new(runtime: AgentRuntime) -> Self

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

pub async fn register_tool( &self, name: String, _description: String, _parameters: Value, )

Register a Python-side tool.

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

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>)

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>

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

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

pub fn cancel(&self)

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) -> ProtocolServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.