Struct RpcLoadShedder 

pub struct RpcLoadShedder { /* private fields */ }

Adaptive admission control for unary Tonic server handlers.

Implementations

impl RpcLoadShedder

pub fn new(config: LoadShedderConfig) -> Self

pub fn current_limit(&self) -> usize

pub fn in_flight(&self) -> usize

pub async fn call<T, F, Fut>(&self, operation: F) -> Result<T, Status>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<T, Status>>,

Admits and observes a unary handler, or rejects it with ResourceExhausted.

Trait Implementations

impl Clone for RpcLoadShedder

fn clone(&self) -> RpcLoadShedder

Returns a duplicate of the value.

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

Performs copy-assignment from source.