Struct ReadonlyClient 

pub struct ReadonlyClient<Client> { /* private fields */ }

A client that will error on requests that write to the network.

Implementations

impl<C: Clone> ReadonlyClient<C>

pub fn builder() -> ReadonlyClientBuilder<C>

Trait Implementations

impl<C> Client for ReadonlyClient<C>

where C: Client,

fn host(&self) -> &str

The URL this transport dials — its connection identity. Two clients share process-level connection state (the XIP-83 shared bidi wire) exactly when their hosts match, so this must name where the bytes actually go: a client behind a proxy reports the proxy’s URL, keeping it a separate failure domain from a direct client to the same backend.

fn has_credential_source(&self) -> bool

Whether this transport stack was given a way to obtain a credential — an auth callback or an auth handle (CFG-062). A stack with no auth middleware in it reports false, and build refuses a deployment that requires authentication.

fn request<'life0, 'async_trait>( &'life0 self, request: Builder, path: PathAndQuery, body: Bytes, ) -> Pin<Box<dyn Future<Output = Result<Response<Bytes>, ApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stream<'life0, 'async_trait>( &'life0 self, request: Builder, path: PathAndQuery, body: Bytes, ) -> Pin<Box<dyn Future<Output = Result<Response<BytesStream>, ApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn bidi_stream<'life0, 'async_trait>( &'life0 self, request: Builder, path: PathAndQuery, body: BoxDynStream<'static, Bytes>, ) -> Pin<Box<dyn Future<Output = Result<Response<BytesStream>, ApiClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Open a bidirectional stream (XIP-83). body is the outbound stream of encoded protobuf messages (one Bytes item per message); the response carries the inbound message stream. Transports without full-duplex support (e.g. gRPC-Web in the browser) keep this default and error.

fn fake_stream(&self) -> Response<BytesStream>

start a “fake” stream that does not create a TCP connection and will always be pending

impl<Client: Clone> Clone for ReadonlyClient<Client>

fn clone(&self) -> ReadonlyClient<Client>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Client: Debug> Debug for ReadonlyClient<Client>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Client: Default> Default for ReadonlyClient<Client>

fn default() -> ReadonlyClient<Client>

Returns the “default value” for a type.

impl<C> IsConnectedCheck for ReadonlyClient<C>

where C: IsConnectedCheck,

fn is_connected<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if a client is connected