Struct OutgoingThrottleLayer 

pub struct OutgoingThrottleLayer { /* private fields */ }

Available on crate feature net only.

A Layer that wraps a Service’s output IO Stream with a byte-rate throttle. See ThrottledIo.

Directions are relative to the established connection: read throttles ingress from the upstream, write paces egress toward it.

Implementations

impl OutgoingThrottleLayer

pub fn symmetric(mode: ThrottleMode) -> OutgoingThrottleLayer

Create a new OutgoingThrottleLayer throttling both directions with the given ThrottleMode.

ThrottleMode::PerConn gives each direction its own (independent) bucket; ThrottleMode::Shared spends both directions from the same aggregate budget.

pub fn read_only(mode: ThrottleMode) -> OutgoingThrottleLayer

Create a new OutgoingThrottleLayer throttling only the read (ingress from upstream) direction.

pub fn write_only(mode: ThrottleMode) -> OutgoingThrottleLayer

Create a new OutgoingThrottleLayer throttling only the write (egress to upstream) direction.

pub fn new( read: Option<ThrottleMode>, write: Option<ThrottleMode>, ) -> OutgoingThrottleLayer

Create a new OutgoingThrottleLayer with per-direction modes.

pub fn maybe_with_quantum(self, quantum: Option<u64>) -> OutgoingThrottleLayer

Override the grant quantum in bytes: the budget reserved per IO operation (clamped to the burst capacity; defaults to a tenth of a period worth of bytes, at most 16 KiB).

pub fn maybe_set_quantum( &mut self, quantum: Option<u64>, ) -> &mut OutgoingThrottleLayer

Override the grant quantum in bytes: the budget reserved per IO operation (clamped to the burst capacity; defaults to a tenth of a period worth of bytes, at most 16 KiB).

pub fn with_quantum(self, quantum: u64) -> OutgoingThrottleLayer

Override the grant quantum in bytes: the budget reserved per IO operation (clamped to the burst capacity; defaults to a tenth of a period worth of bytes, at most 16 KiB).

pub fn set_quantum(&mut self, quantum: u64) -> &mut OutgoingThrottleLayer

Override the grant quantum in bytes: the budget reserved per IO operation (clamped to the burst capacity; defaults to a tenth of a period worth of bytes, at most 16 KiB).

pub fn without_quantum(self) -> OutgoingThrottleLayer

Override the grant quantum in bytes: the budget reserved per IO operation (clamped to the burst capacity; defaults to a tenth of a period worth of bytes, at most 16 KiB).

pub fn unset_quantum(&mut self) -> &mut OutgoingThrottleLayer

Override the grant quantum in bytes: the budget reserved per IO operation (clamped to the burst capacity; defaults to a tenth of a period worth of bytes, at most 16 KiB).

Trait Implementations

impl Clone for OutgoingThrottleLayer

fn clone(&self) -> OutgoingThrottleLayer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutgoingThrottleLayer

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

Formats the value using the given formatter.

impl Default for OutgoingThrottleLayer

fn default() -> OutgoingThrottleLayer

Returns the “default value” for a type.

impl<S> Layer<S> for OutgoingThrottleLayer

type Service = OutgoingThrottleService<S>

The service produced by the layer.

fn layer(&self, inner: S) -> <OutgoingThrottleLayer as Layer<S>>::Service

Wrap the given service with the middleware, returning a new service.

fn into_layer(self, inner: S) -> Self::Service

Same as layer but consuming self after the service was created.