Struct DaemonClient 

pub struct DaemonClient { /* private fields */ }

Implementations

impl DaemonClient

pub async fn connect(metadata: DaemonMetadata) -> Result<DaemonClient, Error>

pub async fn request( &mut self, action: DaemonAction, ) -> Result<DaemonReply, Error>

Speak the daemon’s advertised dialect, not this build’s: management requests must reach daemons of any protocol version, and the frozen subset encodes identically across all of them.

pub async fn status(&mut self) -> Result<DaemonStatus, Error>

pub async fn web_access(&mut self) -> Result<WebViewerAccess, Error>

pub async fn recover_web_viewer( &mut self, action: WebViewerRecovery, ) -> Result<(), Error>

pub async fn inspect_web_listener( &mut self, ) -> Result<Vec<WebListenerProcess>, Error>

pub async fn list_workspaces(&mut self) -> Result<Vec<WorkspaceListing>, Error>

pub async fn rename_profile( &mut self, old_id: String, new_id: String, ) -> Result<(), Error>

pub async fn rename_target( &mut self, old_id: String, new_id: String, ) -> Result<(), Error>

pub async fn create_workspace( &mut self, name: String, ) -> Result<WorkspaceRecord, Error>

pub async fn rename_workspace( &mut self, workspace_id: String, name: String, ) -> Result<(), Error>

pub async fn touch_workspace( &mut self, workspace_id: String, ) -> Result<(), Error>

pub async fn delete_workspace( &mut self, workspace_id: String, ) -> Result<(), Error>

pub async fn attach(&mut self, client_id: String, pid: u32) -> Result<(), Error>

pub async fn detach(&mut self, client_id: String) -> Result<(), Error>

pub async fn persist_read_receipt( &mut self, client_id: String, workspace_id: String, session_id: String, through: u64, ) -> Result<u64, Error>

pub async fn persist_detached_session_state( &mut self, client_id: String, workspace_id: String, session_id: String, through: u64, owner_pid: u32, draft: DetachedSessionDraft, ) -> Result<(), Error>

pub async fn save_active_review( &mut self, session_id: String, review: StoredReview, ) -> Result<(), Error>

pub async fn clear_active_review( &mut self, session_id: String, ) -> Result<(), Error>

pub async fn remember_reviewer_selection( &mut self, workspace_id: String, selection: ReviewerSelection, ) -> Result<(), Error>

pub async fn save_workspace_pane_sizes( &mut self, workspace_id: String, sizes: PaneSizes, ) -> Result<(), Error>

pub async fn persist_imported_session( &mut self, session: SessionRecord, ) -> Result<(), Error>

pub async fn set_session_title( &mut self, session_id: String, title: String, ) -> Result<String, Error>

pub async fn set_session_container_settings( &mut self, session_id: String, cpus: Option<String>, memory: Option<String>, mounts: Vec<AdditionalMount>, mount_history: Vec<PathBuf>, ) -> Result<(), Error>

pub async fn set_session_acp_title( &mut self, session_id: String, title: Option<String>, ) -> Result<(), Error>

pub async fn mark_session_target_missing( &mut self, session_id: String, detail: String, updated_at: String, ) -> Result<Option<SessionState>, Error>

pub async fn checkpoint_session( &mut self, session_id: String, ) -> Result<CheckpointMetadata, Error>

pub async fn scan_recovery(&mut self) -> Result<RecoveryScan, Error>

pub async fn adopt_recovery( &mut self, session_id: String, target_id: String, profile: Option<String>, bundle: Option<String>, ) -> Result<(), Error>

pub async fn destroy_recovery( &mut self, session_id: String, target_id: String, confirmation: String, ) -> Result<(), Error>

pub async fn snapshot( &mut self, workspace_id: String, ) -> Result<WorkspaceSnapshot, Error>

pub async fn runtime_snapshot( &mut self, workspace_id: String, after_revision: u64, all_workspaces: bool, ) -> Result<RuntimeSnapshot, Error>

pub async fn submit_session_command( &mut self, session_id: String, command_id: String, command: RelayCommand, inherited_draft: Option<String>, ) -> Result<u64, Error>

pub async fn start_turn_review( &mut self, session_id: String, ) -> Result<(), Error>

Ask the daemon to review the turn this session just finished.

The refusal is a sentence for a person – “prompts are queued”, “set [review] profile in config.toml” – so it travels as text rather than as a code every surface would have to translate.

pub async fn resolve_turn_review( &mut self, session_id: String, resolution: Resolution, ) -> Result<(), Error>

pub async fn reviewer_action( &mut self, session_id: String, role: Option<String>, action: ReviewerAction, ) -> Result<ReviewerOutcome, Error>

pub async fn sync_session(&mut self, session_id: String) -> Result<(), Error>

pub async fn respond_elicitation( &mut self, session_id: String, elicitation_id: String, response: ElicitationResponse, ) -> Result<(), Error>

pub async fn stop_background_task( &mut self, session_id: String, background_task_id: String, ) -> Result<(), Error>

pub async fn close_session(&mut self, session_id: String) -> Result<(), Error>

pub async fn start_create_session( &mut self, request: CreateSessionRequest, ) -> Result<RegisteredSession, Error>

pub async fn wait_create_session( &mut self, session_id: String, ) -> Result<(), Error>

pub async fn resume_session( &mut self, request: ResumeSessionRequest, ) -> Result<(), Error>

pub async fn force_stop_session( &mut self, session_id: String, ) -> Result<(), Error>

pub async fn destroy_stopped_session( &mut self, session_id: String, ) -> Result<(), Error>

pub async fn force_destroy_session( &mut self, session_id: String, ) -> Result<(), Error>

pub async fn force_delete_workspace( &mut self, workspace_id: String, ) -> Result<(), Error>

pub async fn cancel_lifecycle( &mut self, session_id: String, ) -> Result<(), Error>

pub async fn recover_draft(&mut self, draft_id: String) -> Result<(), Error>

pub async fn stop(&mut self) -> Result<(), Error>

impl DaemonClient

pub async fn prepare_move_session( &mut self, selection: MoveSelection, ) -> Result<MovePreparation, Error>

pub async fn move_session( &mut self, request: MoveSessionRequest, ) -> Result<MoveOutcome, Error>