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 download( &mut self, req: DownloadRequest, ) -> impl Stream<Item = Result<DownloadEvent, Error>> + Send

Download a model’s files with progress reporting.

fn hub( &mut self, req: HubRequest, ) -> impl Stream<Item = Result<HubEvent, Error>> + Send

Install or uninstall a hub package, streaming progress events.

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

Ping the server (keepalive).