Struct Remote 

pub struct Remote<T: RpcTransport<Error = Error>> {
    pub api: Client<T>,
    pub description: DescribeEndpointResponse,
}

One authenticated source. A combined Thread retains one source per endpoint; a hosted action is sent directly to the Weft source, never via a device.

Fields

api: Client<T>

description: DescribeEndpointResponse

Implementations

impl<T: RpcTransport<Error = Error>> Remote<T>

pub async fn read_blobs( &self, thread: ThreadRef, revision: RevisionRef, sources: Vec<BlobSource>, ) -> Result<Vec<Blob>, Error>

One request for any mixture of paths and missing object hashes. The The selected Thread and revision pin content and authorization without a mutable Thread-tip lookup.

impl<T: RpcTransport<Error = Error>> Remote<T>

pub async fn start_thread( &self, creation: &ThreadCreation, ) -> Result<ThreadMutationResponse, ClientError<Error>>

One command returns its receipt and resulting overview. Bind subsequent calls with remote.thread(creation.reference().clone()), without lookup.

impl<T: RpcTransport<Error = Error>> Remote<T>

pub async fn begin_provider_fetch( &self, open: FetchOpen, limits: Limits, ) -> Result<ProviderFetch<T::Writer, T::Reader>, Error>

impl<T: RpcTransport<Error = Error>> Remote<T>

pub async fn fetch_content( &self, open: FetchOpen, limits: Limits, ) -> Result<Download<T::Reader>, Error>

A single exact Thread/revision request returns clone admission, immutable operations, and bounded source artifacts. No reference update is implied.

impl<T: RpcTransport<Error = Error>> Remote<T>

pub async fn publish_content<R: AsyncRead + Unpin + Send>( &self, opening: &PublishContentClientFrame, originals: &PublicationOriginals, artifacts: [R; 2], ) -> Result<PublicationReceipt, Error>

Publish original source proofs and exact source in one exchange. Inputs are the native pack and its index in opening order; neither is buffered in full. The caller retains the operation ID and opening to retry after an interrupted call. A receipt is returned only after verifying its exact publication scope.

impl<T: RpcTransport<Error = Error>> Remote<T>

pub async fn discover( transport: T, endpoint_key: [u8; 32], kind: EndpointKind, ) -> Result<Self, ClientError<Error>>

The caller supplies the Iroh-authenticated endpoint key and intended kind. Describe is the only bootstrap exception to implemented-method discovery.

pub async fn observe<M>( &self, request: M::Request, resume: Option<Resume>, ) -> Result<Observation<T::Reader, M::Response>, Error>

where M: ServerStreamingRpc, M::Request: ObservationRequest, M::Response: ObservedEvent,

Observe any contract view as atomic bounded batches. The bookmark binds the exact method and projection as well as the authenticated endpoint.

pub async fn observe_analysis( &self, request: ObserveAnalysisRequest, resume: Option<Resume>, ) -> Result<AnalysisObservation<T::Reader>, Error>

Source-backed analysis uses the same committed view protocol as identity, collaboration, checkouts and Thread observations.

pub fn thread(&self, thread: ThreadRef) -> Thread<'_, T>

Binding a Thread is local and costs no RPC. Persist this stable reference when discovering/creating the Thread; its display name is never its key.