Struct DaemonClient 

pub struct DaemonClient { /* private fields */ }

Typed async client for communicating with the vex daemon.

Implementations

impl DaemonClient

pub fn new(port: u16) -> Self

pub fn port(&self) -> u16

pub async fn connect(&self) -> Result<TcpStream>

Open a raw TCP connection to the daemon.

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

One-shot request-response: connect, send, read one control frame.

pub async fn shell_spawn( &self, workdir: Option<String>, name: Option<String>, workstream_id: Option<WorkstreamId>, attach: bool, ) -> Result<ShellId>

pub async fn shell_list(&self) -> Result<Vec<ShellInfo>>

pub async fn shell_kill(&self, id: ShellId) -> Result<()>

pub async fn shell_send( &self, id: ShellId, text: Option<String>, keys: Option<Vec<String>>, ) -> Result<()>

pub async fn shell_screenshot(&self, id: ShellId) -> Result<String>

pub async fn shell_logs( &self, id: ShellId, last: Option<usize>, ) -> Result<String>

pub async fn agent_spawn( &self, workdir: Option<String>, prompt: Option<String>, workstream_id: Option<WorkstreamId>, ) -> Result<(AgentId, ShellId)>

pub async fn agent_list(&self) -> Result<Vec<AgentInfo>>

pub async fn agent_send(&self, id: AgentId, message: &str) -> Result<()>

pub async fn agent_kill(&self, id: AgentId) -> Result<()>

pub async fn agent_pause(&self, id: AgentId) -> Result<()>

pub async fn agent_resume( &self, id: AgentId, prompt: Option<String>, ) -> Result<()>

pub async fn agent_history(&self, id: AgentId) -> Result<Vec<String>>

pub async fn agent_screenshot(&self, id: AgentId) -> Result<String>

pub async fn ws_create( &self, name: &str, branch: Option<&str>, repo: Option<&str>, issue: Option<&str>, from: Option<&str>, ) -> Result<WorkstreamId>

pub async fn ws_list(&self) -> Result<Vec<WorkstreamInfo>>

pub async fn ws_show( &self, id: WorkstreamId, ) -> Result<(WorkstreamInfo, Vec<ShellInfo>, Vec<AgentInfo>, Vec<EventEntry>)>

pub async fn ws_switch(&self, id: WorkstreamId) -> Result<()>

pub async fn ws_pause(&self, id: Option<WorkstreamId>) -> Result<()>

pub async fn ws_resume(&self, id: Option<WorkstreamId>) -> Result<()>

pub async fn ws_complete(&self, id: Option<WorkstreamId>) -> Result<()>

pub async fn ws_abandon(&self, id: Option<WorkstreamId>) -> Result<()>

pub async fn ws_note(&self, id: WorkstreamId, text: &str) -> Result<()>

pub async fn repo_list(&self) -> Result<Vec<RepoInfo>>

pub async fn repo_status(&self, path: Option<&str>) -> Result<RepoStatusInfo>

pub async fn repo_branches( &self, path: Option<&str>, ) -> Result<Vec<RepoBranchInfo>>

pub async fn repo_log( &self, path: Option<&str>, last: Option<usize>, ) -> Result<Vec<CommitInfo>>

pub async fn repo_watch(&self, path: &str) -> Result<()>

pub async fn repo_unwatch(&self, path: &str) -> Result<()>

pub async fn skill_list(&self) -> Result<Vec<SkillInfo>>

pub async fn skill_info(&self, name: &str) -> Result<SkillInfo>

pub async fn gh_auth(&self) -> Result<(String, Vec<String>)>

pub async fn daemon_status(&self) -> Result<DaemonStatusInfo>