Struct RemoteServices 

pub struct RemoteServices { /* private fields */ }

Implementations

impl RemoteServices

pub fn load_snapshot( &self, snapshot: FileSnapshot, document: DocumentID, recovery: Option<&RecoveryStore>, ) -> Result<(LoadedDocument, LoadBudget), CoreError>

pub fn save_prepared( &self, recovery: &RecoveryStore, prepared: PreparedSave, ) -> OperationReceipt

impl RemoteServices

pub fn prepare_owned_save( &self, request: SaveRequest, ) -> Result<RemoteOwnedSave, CoreError>

pub fn prepare_owned_document( &self, recovery: &RecoveryStore, prepared: PreparedSave, ) -> Result<RemoteOwnedSave, CoreError>

impl RemoteServices

pub fn observe_owned<'a>( &self, worktree: WorktreeIdentity, aliases: impl Iterator<Item = &'a FileRef> + Clone, on_event: impl FnMut(ObservationEvent) -> Result<(), CoreError>, ) -> Result<OwnedObservation, CoreError>

Freeze the complete aliases under the caller’s registration barrier. Events remain provisional until this method validates the complete codec and authenticated end seal.

pub fn existing_original( &self, original: &GitMutationRequest, ) -> Result<Option<OperationReceipt>, CoreError>

Worker-only existing lookup. This cannot promote a missing original into new work.

pub fn prepare_worktree<'a>( &self, original: &GitMutationRequest, observation: [u8; 16], alias_digest: [u8; 32], approvals: impl Iterator<Item = &'a GitSaveApproval> + Clone, ) -> Result<WorktreePreparation, CoreError>

Existing receipt wins before approval iteration. Preserve the original ID on every error.

pub fn execute_worktree<'a>( &self, original: GitMutationRequest, plan: [u8; 16], alias_digest: [u8; 32], approvals: impl Iterator<Item = &'a GitSaveApproval> + Clone, ) -> Result<OperationReceipt, CoreError>

pub fn cancel_worktree_plan(&self, plan: [u8; 16]) -> Result<(), CoreError>

pub fn release_observation( &self, observation: [u8; 16], ) -> Result<(), CoreError>

impl RemoteServices

pub fn connect( socket: UnixStream, target: TargetIdentity, lease: WorkspaceLease, spool_directory: PathBuf, ) -> Result<Self, CoreError>

The route owner supplies an authenticated byte transport and verified target, never a display hostname.

pub fn register_workspace( &self, lease: WorkspaceLease, ) -> Result<Self, CoreError>

Worker-only registration; all views share the existing wire worker and spool pool.

pub fn observe_owner( &self, owner: WorkspaceLease, ) -> Result<LeaseObservation, CoreError>

Worker-only, read-only observation of an exact prior owner.

pub fn lease(&self) -> &WorkspaceLease

pub fn target(&self) -> &TargetIdentity

pub fn validate_environment_ready(&self) -> Result<(), CoreError>

pub fn negotiated_capabilities(&self) -> &[String]

pub fn release_workspace( &self, intent: LeaseReleaseIntent, ) -> Result<(), CoreError>

Revokes this view’s new-work authority; other registered views remain connected.

pub fn close_connection(&self) -> RemoteShutdown

Physical-route owner only. Drop the SSH channel separately and await both shutdowns off the owner thread.

pub fn set_authentication( &self, ssh_auth_sock: Option<TargetPath>, ) -> Result<(), CoreError>

pub fn runtime(&self) -> RuntimeGeneration

pub fn connection_state(&self) -> ConnectionState

pub fn contains_document( &self, worktree: WorktreeIdentity, file: FileRef, ) -> Result<bool, CoreError>

pub fn path_version(&self, file: FileRef) -> Result<FileVersion, CoreError>

Trait Implementations

impl Clone for RemoteServices

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl FileService for RemoteServices

fn resolve( &self, root: FileRef, purpose: FileResolvePurpose, ) -> ServiceFuture<'_, Result<FileResolution, CoreError>>

fn list( &self, file: FileRef, ) -> ServiceFuture<'_, Result<Vec<FileEntry>, CoreError>>

fn read( &self, file: FileRef, ) -> ServiceFuture<'_, Result<FileSnapshot, CoreError>>

fn save(&self, r: SaveRequest) -> ServiceFuture<'_, OperationReceipt>

fn mutate(&self, r: FileMutationRequest) -> ServiceFuture<'_, OperationReceipt>

fn watch( &self, file: FileRef, ) -> ServiceFuture<'_, Result<EventStream<FileEvent>, CoreError>>

impl GitService for RemoteServices

fn repository( &self, worktree: WorktreeIdentity, ) -> ServiceFuture<'_, Result<GitRepositorySnapshot, CoreError>>

fn commit( &self, query: CommitQuery, ) -> ServiceFuture<'_, Result<CommitPage, CoreError>>

fn read_query( &self, worktree: WorktreeIdentity, query: GitRead, ) -> ServiceFuture<'_, Result<GitReadOutput, CoreError>>

fn existing_receipt( &self, r: GitMutationRequest, ) -> ServiceFuture<'_, Result<Option<OperationReceipt>, CoreError>>

Read-only original-request lookup, before filesystem or expected-state validation.

fn discover( &self, file: FileRef, ) -> ServiceFuture<'_, Result<Option<WorktreeIdentity>, CoreError>>

fn status( &self, worktree: WorktreeIdentity, ) -> ServiceFuture<'_, Result<GitSnapshot, CoreError>>

fn diff( &self, r: DiffRequest, ) -> ServiceFuture<'_, Result<DiffSnapshot, CoreError>>

fn history( &self, r: HistoryQuery, ) -> ServiceFuture<'_, Result<GraphPage, CoreError>>

fn mutate(&self, r: GitMutationRequest) -> ServiceFuture<'_, OperationReceipt>

impl OperationService for RemoteServices

fn inspect( &self, id: OperationID, target: TargetIdentity, ) -> ServiceFuture<'_, Result<OperationReceipt, CoreError>>

impl SearchService for RemoteServices

fn search( &self, r: SearchRequest, ) -> ServiceFuture<'_, Result<EventStream<SearchEvent>, CoreError>>

impl TerminalService for RemoteServices

fn open(&self, r: TerminalOpenRequest) -> ServiceFuture<'_, OperationReceipt>

fn attach( &self, r: TerminalAttachRequest, ) -> ServiceFuture<'_, Result<EventStream<TerminalEvent>, CoreError>>

fn input( &self, session: TerminalSessionID, bytes: Vec<u8>, ) -> ServiceFuture<'_, Result<(), CoreError>>

fn resize( &self, session: TerminalSessionID, size: TerminalSize, ) -> ServiceFuture<'_, Result<(), CoreError>>

fn end( &self, session: TerminalSessionID, intent: TerminalEndIntent, ) -> ServiceFuture<'_, Result<(), CoreError>>

impl WorkspaceLeaseService for RemoteServices

fn register( &self, lease: WorkspaceLease, ) -> ServiceFuture<'_, Result<(), CoreError>>

fn release( &self, id: WorkspaceLeaseID, intent: LeaseReleaseIntent, ) -> ServiceFuture<'_, Result<(), CoreError>>