Struct Connection 

pub struct Connection { /* private fields */ }

An established Unix domain socket connection to a walrus daemon.

Not Clone — one connection per session. Use WalrusClient::connect to create a connection.

Implementations

impl Connection

pub async fn connect(socket_path: &Path) -> Result<Self>

Connect to a daemon at the given socket path.

Trait Implementations

impl Client for Connection

async fn request(&mut self, msg: ClientMessage) -> Result<ServerMessage>

Send a ClientMessage and receive a single ServerMessage.

fn request_stream( &mut self, msg: ClientMessage, ) -> impl Stream<Item = Result<ServerMessage>> + Send + '_

Send a ClientMessage and receive a stream of ServerMessages.

fn send( &mut self, req: SendRequest, ) -> impl Future<Output = Result<SendResponse, Error>> + Send

Send a message to an agent and receive a complete response.

fn stream( &mut self, req: StreamRequest, ) -> impl Stream<Item = Result<StreamEvent, Error>> + Send

Send a message to an agent and receive a streamed response.

fn clear_session( &mut self, req: ClearSessionRequest, ) -> impl Future<Output = Result<SessionCleared, Error>> + Send

Clear the session history for an agent.

fn list_agents( &mut self, ) -> impl Future<Output = Result<AgentList, Error>> + Send

List all registered agents.

fn agent_info( &mut self, req: AgentInfoRequest, ) -> impl Future<Output = Result<AgentDetail, Error>> + Send

Get detailed info for a specific agent.

fn list_memory( &mut self, ) -> impl Future<Output = Result<MemoryList, Error>> + Send

List all memory entries.

fn get_memory( &mut self, req: GetMemoryRequest, ) -> impl Future<Output = Result<MemoryEntry, Error>> + Send

Get a specific memory entry by key.

fn download( &mut self, req: DownloadRequest, ) -> impl Stream<Item = Result<DownloadEvent, Error>> + Send

Download a model’s files with progress reporting.

fn reload_skills( &mut self, ) -> impl Future<Output = Result<SkillsReloaded, Error>> + Send

Reload skills from disk.

fn mcp_add( &mut self, req: McpAddRequest, ) -> impl Future<Output = Result<McpAdded, Error>> + Send

Add an MCP server.

fn mcp_remove( &mut self, req: McpRemoveRequest, ) -> impl Future<Output = Result<McpRemoved, Error>> + Send

Remove an MCP server.

fn mcp_reload( &mut self, ) -> impl Future<Output = Result<McpReloaded, Error>> + Send

Reload MCP servers from config.

fn mcp_list( &mut self, ) -> impl Future<Output = Result<McpServerList, Error>> + Send

List connected MCP servers.

fn ping(&mut self) -> impl Future<Output = Result<(), Error>> + Send

Ping the server (keepalive).