Struct BackpressureTransport 

pub struct BackpressureTransport { /* private fields */ }

A transport wrapper that limits concurrent in-flight requests.

If max_in_flight requests are already pending, new requests immediately fail with TransportError::Overloaded.

Implementations

impl BackpressureTransport

pub fn new(inner: Arc<dyn RpcTransport>, config: BackpressureConfig) -> Self

Create a new backpressure wrapper.

pub fn in_flight(&self) -> usize

Current number of in-flight requests.

pub fn is_full(&self) -> bool

Whether the transport is at capacity.

Trait Implementations

impl RpcTransport for BackpressureTransport

fn send<'life0, 'async_trait>( &'life0 self, req: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcResponse, TransportError>> + Send + 'async_trait>>

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

Send a single JSON-RPC request and return the response.

fn health(&self) -> HealthStatus

Return the current health status of this transport.

fn url(&self) -> &str

Return the transport’s identifier (URL or name).

fn send_batch<'life0, 'async_trait>( &'life0 self, reqs: Vec<JsonRpcRequest>, ) -> Pin<Box<dyn Future<Output = Result<Vec<JsonRpcResponse>, TransportError>> + Send + 'async_trait>>

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

Send a batch of JSON-RPC requests.

fn call<'life0, 'life1, 'async_trait, T>( &'life0 self, id: u64, method: &'life1 str, params: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<T, TransportError>> + Send + 'async_trait>>

where Self: Sized + 'async_trait, T: 'async_trait + DeserializeOwned, 'life0: 'async_trait, 'life1: 'async_trait,

Convenience: call a method and deserialize the result.