Struct AgentClient 

pub struct AgentClient { /* private fields */ }

Adapter that bridges TUI’s AppCommand/AppEvent interface with gRPC streaming

Implementations

impl AgentClient

pub async fn connect(addr: &str) -> Result<Self, GrpcError>

Connect to a gRPC server

pub async fn from_channel(channel: Channel) -> Result<Self, GrpcError>

Create client from an existing channel (for in-memory connections)

pub async fn local(default_model: ModelId) -> Result<Self, GrpcError>

Convenience constructor: spin up a localhost gRPC server and return a ready client.

pub async fn create_session( &self, config: SessionConfig, ) -> Result<String, GrpcError>

Create a new session on the server

pub async fn activate_session( &self, session_id: String, ) -> Result<(Vec<Message>, Vec<String>), GrpcError>

Activate (load) an existing dormant session and get its state

pub async fn start_streaming(&self) -> Result<(), GrpcError>

Start bidirectional streaming with the server

pub async fn send_command(&self, command: AppCommand) -> Result<(), GrpcError>

Send a command to the server

pub async fn session_id(&self) -> Option<String>

Get the current session ID

pub async fn list_sessions(&self) -> Result<Vec<SessionInfo>, GrpcError>

List sessions on the remote server

pub async fn get_session( &self, session_id: &str, ) -> Result<Option<SessionState>, GrpcError>

Get session details from the remote server

pub async fn delete_session(&self, session_id: &str) -> Result<bool, GrpcError>

Delete a session on the remote server

pub async fn get_conversation( &self, session_id: &str, ) -> Result<(Vec<Message>, Vec<String>), GrpcError>

Get the current conversation for a session

pub async fn shutdown(self)

Shutdown the adapter and clean up resources

pub async fn get_mcp_servers(&self) -> Result<Vec<McpServerInfo>, GrpcError>

pub async fn resolve_model(&self, input: &str) -> Result<ModelId, GrpcError>

Resolve a model string (alias or provider/model) to a ModelId

pub async fn list_providers(&self) -> Result<Vec<ProviderInfo>, GrpcError>

List providers from server

pub async fn get_provider_auth_status( &self, provider_id: Option<String>, ) -> Result<Vec<ProviderAuthStatus>, GrpcError>

Get provider auth status from server

pub async fn list_models( &self, provider_id: Option<String>, ) -> Result<Vec<ProviderModel>, GrpcError>

List available models (only recommended ones)

Trait Implementations

impl AppCommandSink for AgentClient

fn send_command<'life0, 'async_trait>( &'life0 self, command: AppCommand, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a command to the application core.

impl AppEventSource for AgentClient

fn subscribe<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Receiver<AppEvent>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Obtain a receiver that yields application events. A fresh receiver should be returned on every call so multiple consumers can coexist.