Struct RemoteClient 

pub struct RemoteClient { /* private fields */ }

A DecisionBackend over rustev.remote/1. Clones share state.

Implementations

impl RemoteClient

pub async fn connect( config: ClientConfig, sink: Arc<dyn ExchangeSink>, ) -> Result<RemoteClient, SetupError>

Construct the adapter: check the configuration, negotiate the protocol version, and obtain the remote descriptor and terms. The descriptor this adapter then returns is fixed for its lifetime.

pub fn terms(&self) -> &RemoteTerms

The negotiated terms.

pub fn remote_descriptor(&self) -> (&BackendDescriptor, &DescriptorId)

The remote backend’s own descriptor and its identity, as negotiated.

pub fn binding(&self) -> &ArtifactId

The adapter binding identity: this adapter’s artifact.

pub fn max_items(&self) -> usize

Items per exchange: 1 unless batching is on and offered.

pub fn exchange_stats(&self) -> ExchangeStats

Trait Implementations

impl Clone for RemoteClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DecisionBackend for RemoteClient

fn cost_model(&self) -> CostModel

bounded only when the remote side enforces a per-call maximum it declared (3.8.1).

fn batch_capability(&self, projection: &[u8]) -> Option<BatchCapability>

Offered only when the binding enables runtime-planned batches and the negotiated terms declare shared-state batching (spec 020, 3.3). Any per-item operation disables batching for the entire backend (spec 035, 3.15.3, and spec 044, 3.7); the projected operation must also be declared. Equal compatibility means the same binding and the same shared state (instance and values), which is what one request may carry.

fn descriptor(&self) -> &BackendDescriptor

fn cost_bound(&self, _projection: &[u8]) -> CostBound

Per-call disclosure before dispatch. A bounded model returns bounded; fractional costs are rounded up.

fn infer<'a>(&'a self, call: AttemptCall<'a>) -> BoxFuture<'a, AttemptReport>

fn take_remote_evidence(&self, attempt_id: &str) -> Option<RemoteEvidence>

The remote evidence of an attempt this backend ran, for a rustev.run/2 record (spec 020, 3.2), taken once: the adapter’s part of the entry (exchange reference, identities, binding, code, charge provenance); the runtime sets the step, instance and final remote state. None, the default, for an in-process backend.

fn infer_batch<'a>( &'a self, call: BatchAttemptCall, ) -> BoxFuture<'a, BatchAttemptReport>

Dispatch a declared-compatible batch. The default is unreachable for a backend that keeps the default batch_capability implementation.

fn infer_generation<'a>( &'a self, call: AttemptCall<'a>, _fields: &'a dyn GenerationFields, ) -> Pin<Box<dyn Future<Output = AttemptReport> + Send + 'a>>

Optional generation streaming. Existing backends return their ordinary complete report without emitting provisional fields.