Struct ExecServerClient 

pub struct ExecServerClient { /* private fields */ }

Implementations

impl ExecServerClient

pub async fn http_request( &self, params: HttpRequestParams, ) -> Result<HttpRequestResponse, ExecServerError>

Performs an HTTP request and buffers the response body.

pub async fn http_request_stream( &self, params: HttpRequestParams, ) -> Result<(HttpRequestResponse, HttpResponseBodyStream), ExecServerError>

Performs an HTTP request and returns a body stream.

The method sets stream_response and replaces any caller-supplied request_id with a connection-local id, so late deltas from abandoned streams cannot be confused with later requests.

impl ExecServerClient

pub async fn exec( &self, params: ExecParams, ) -> Result<ExecResponse, ExecServerError>

pub async fn environment_info(&self) -> Result<EnvironmentInfo, ExecServerError>

pub async fn environment_status( &self, ) -> Result<EnvironmentStatus, ExecServerError>

pub async fn discover_capability_roots( &self, params: CapabilityRootsDiscoverParams, ) -> Result<CapabilityRootsDiscoverResponse, ExecServerError>

pub async fn read( &self, params: ReadParams, ) -> Result<ReadResponse, ExecServerError>

pub async fn write( &self, process_id: &ProcessId, chunk: Vec<u8>, write_id: String, ) -> Result<WriteResponse, ExecServerError>

pub async fn signal( &self, process_id: &ProcessId, signal: ProcessSignal, ) -> Result<(), ExecServerError>

pub async fn terminate( &self, process_id: &ProcessId, ) -> Result<TerminateResponse, ExecServerError>

pub async fn fs_read_file( &self, params: FsReadFileParams, ) -> Result<FsReadFileResponse, ExecServerError>

pub async fn fs_open( &self, params: FsOpenParams, ) -> Result<FsOpenResponse, ExecServerError>

pub async fn fs_read_block( &self, params: FsReadBlockParams, ) -> Result<FsReadBlockResponse, ExecServerError>

pub async fn fs_close( &self, params: FsCloseParams, ) -> Result<FsCloseResponse, ExecServerError>

pub async fn fs_write_file( &self, params: FsWriteFileParams, ) -> Result<FsWriteFileResponse, ExecServerError>

pub async fn fs_create_directory( &self, params: FsCreateDirectoryParams, ) -> Result<FsCreateDirectoryResponse, ExecServerError>

pub async fn fs_get_metadata( &self, params: FsGetMetadataParams, ) -> Result<FsGetMetadataResponse, ExecServerError>

pub async fn fs_canonicalize( &self, params: FsCanonicalizeParams, ) -> Result<FsCanonicalizeResponse, ExecServerError>

pub async fn fs_read_directory( &self, params: FsReadDirectoryParams, ) -> Result<FsReadDirectoryResponse, ExecServerError>

pub async fn fs_walk( &self, params: FsWalkParams, ) -> Result<FsWalkResponse, ExecServerError>

pub async fn fs_remove( &self, params: FsRemoveParams, ) -> Result<FsRemoveResponse, ExecServerError>

pub async fn fs_copy( &self, params: FsCopyParams, ) -> Result<FsCopyResponse, ExecServerError>

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

impl ExecServerClient

pub async fn connect_websocket( args: RemoteExecServerConnectArgs, ) -> Result<Self, ExecServerError>

pub async fn connect_noise_rendezvous( args: NoiseRendezvousConnectArgs, ) -> Result<Self, ExecServerError>

Connect to one exec-server through an authenticated rendezvous stream using a caller-supplied single-use authorization bundle.

The executor key is pinned before JSON-RPC starts; the websocket carries only ciphertext after that. Environment-managed connections use a retained NoiseRendezvousConnectProvider so recovery can fetch a fresh bundle for each reconnect.

Trait Implementations

impl Clone for ExecServerClient

fn clone(&self) -> ExecServerClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl HttpClient for ExecServerClient

fn http_request( &self, params: HttpRequestParams, ) -> BoxFuture<'_, Result<HttpRequestResponse, ExecServerError>>

Orchestrator-side adapter that forwards buffered HTTP requests to the remote runtime over the shared JSON-RPC connection.

fn http_request_stream( &self, params: HttpRequestParams, ) -> BoxFuture<'_, Result<(HttpRequestResponse, HttpResponseBodyStream), ExecServerError>>

Orchestrator-side adapter that forwards streamed HTTP requests to the remote runtime and exposes body deltas as a byte stream.