Struct RemoteContextClient 

pub struct RemoteContextClient { /* private fields */ }

The client. Clones share the queue and counters.

Implementations

impl RemoteContextClient

pub async fn connect( transport: HttpTransport, config: ContextClientConfig, exchanges: Option<ExchangeSink>, ) -> Result<Self, String>

Describe the endpoint and select config.source_id.

pub fn source(&self) -> &HostedSource

What the endpoint described for this source.

pub fn describe_digest(&self) -> &ContentDigest

pub fn counters(&self) -> SeamCounters

Queue depth, refusals and late discards (3.12.4).

pub fn exchange_failures(&self) -> u64

Exchange records the host’s exchange sink failed to take.

pub async fn cancel( &self, attempt_ids: Vec<String>, budget_ms: u64, ) -> Result<Vec<CancelItem>, String>

Ask the endpoint to cancel attempts (3.10.4).

pub async fn invalidations( &self, sequence: Option<u64>, budget_ms: u64, ) -> Result<InvalidationsResponse, String>

Poll invalidations after sequence, or the baseline with None (3.10.6). Applying them is the caller’s.

impl RemoteContextClient

pub fn acquisition_source(&self) -> Option<RemoteAcquisitionSource>

The source’s acquisitions, when describe carried its descriptor.

Trait Implementations

impl Clone for RemoteContextClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ContextSource for RemoteContextClient

fn fetch<'a>( &'a self, fields: &'a [String], cx: &'a CallContext, ) -> BoxFuture<'a, Result<Snapshot, String>>