pub struct FlowControlMetrics { /* private fields */ }Implementations§
Source§impl FlowControlMetrics
impl FlowControlMetrics
pub fn new() -> Self
pub fn update_window_size(&mut self, new_size: usize)
pub fn record_bytes_sent(&mut self, bytes: usize)
pub fn record_bytes_acked(&mut self, bytes: usize)
pub fn window_size(&self) -> usize
pub fn bytes_in_flight(&self) -> usize
pub fn available_window(&self) -> usize
pub fn should_send(&self) -> bool
pub fn update_rtt(&mut self, rtt: Duration)
pub fn estimated_rtt(&self) -> Duration
pub fn record_bytes_received(&mut self, bytes: usize)
pub fn record_request_start(&mut self)
pub fn record_request_complete(&mut self)
pub fn calculate_throughput(&self) -> f64
pub fn should_throttle(&self) -> bool
Trait Implementations§
Source§impl Clone for FlowControlMetrics
impl Clone for FlowControlMetrics
Source§fn clone(&self) -> FlowControlMetrics
fn clone(&self) -> FlowControlMetrics
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for FlowControlMetrics
impl Debug for FlowControlMetrics
Auto Trait Implementations§
impl Freeze for FlowControlMetrics
impl RefUnwindSafe for FlowControlMetrics
impl Send for FlowControlMetrics
impl Sync for FlowControlMetrics
impl Unpin for FlowControlMetrics
impl UnsafeUnpin for FlowControlMetrics
impl UnwindSafe for FlowControlMetrics
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].