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 wiki_search( &mut self, query: String, limit: usize, ) -> Result<WikiSearchPage, Error>

Search the user’s SessionWiki index, newest first when the query is empty and best match first otherwise. The reply carries the state of the index as well as the rows, so a caller can say the first build is still running.

pub async fn wiki_brief( &mut self, wiki_id: String, max_chars: usize, ) -> Result<String, Error>

The markdown briefing for one indexed session.

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

Start a new session carrying a hand-off compacted from an archived one. It answers like any other session start: the record exists and is provisioning, and the hand-off follows once the harness is ready.

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

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

pub async fn destroy_recovery( &mut self, session_id: String, target_id: String, confirmation: String, all_instances: bool, ) -> 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>