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: SendMsg, ) -> impl Future<Output = Result<SendResponse, Error>> + Send

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

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

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

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

Install or uninstall a hub package, streaming download events.

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

Ping the server (keepalive).

fn subscribe_tasks(&mut self) -> impl Stream<Item = Result<Event, Error>> + Send

Subscribe to task lifecycle events.

fn subscribe_downloads( &mut self, ) -> impl Stream<Item = Result<Event, Error>> + Send

Subscribe to download lifecycle events.

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

Get the full daemon config as JSON.

fn set_config( &mut self, config: String, ) -> impl Future<Output = Result<(), Error>> + Send

Replace the full daemon config from JSON.

fn service_query( &mut self, service: String, query: String, ) -> impl Future<Output = Result<String, Error>> + Send

Query a named service.