Struct CoalescingClient 

pub struct CoalescingClient<C> {
    pub inner: C,
    /* private fields */
}

A coalescing + optional-cache wrapper around a tonic-generated client.

Call CoalescingClient::call from within generated method wrappers, passing the encoded request bytes, service path, method name, and the upstream closure. Coalescing and caching are handled transparently.

Fields

inner: C

The wrapped tonic-generated client.

Implementations

impl<C> CoalescingClient<C>

pub fn new(inner: C) -> Self

Wrap inner with default config (coalescing ON, no cache).

pub fn builder(inner: C) -> CoalescingClientBuilder<C>

Start a builder for granular per-method configuration.

pub async fn call<R, F, Fut>( &self, service: &str, method: &str, req_bytes: Vec<u8>, upstream: F, ) -> Result<Response<R>, Status>

where R: Clone + Send + Sync + 'static, F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<Response<R>, Status>> + Send + 'static,

Execute a coalesced (and optionally cached) unary call.

• service: gRPC service path, e.g. "auth.v1.AuthService".
• method: method name, e.g. "Check".
• req_bytes: prost::Message::encode_to_vec(&request) — the caller encodes once and passes the bytes for key derivation.
• upstream: async closure that performs the actual tonic call and returns Result<Response<R>, Status>.

R must be Clone + Send + Sync + 'static so it can be shared across waiters and stored in the cache.

Streaming calls must not use this method. Pass through to self.inner directly.