pub struct ConcurrencyConfig {
pub max_in_flight: usize,
pub scope: Option<ScopeConfig>,
}Expand description
Request concurrency limit: requests past max_in_flight are answered
UNAVAILABLE (503) at once instead of queueing.
Fields§
§max_in_flight: usizeMost requests in flight at once, counted until each response body ends, so a stream holds its slot for its whole life. At least 1.
scope: Option<ScopeConfig>The traffic the limit covers, one budget shared by all of it.
Default: transcoded and grpc; the proxy’s own endpoints stay out,
so health probes answer while the proxy is saturated.
Trait Implementations§
Source§impl Clone for ConcurrencyConfig
impl Clone for ConcurrencyConfig
Source§impl Debug for ConcurrencyConfig
impl Debug for ConcurrencyConfig
Source§impl<'de> Deserialize<'de> for ConcurrencyConfig
impl<'de> Deserialize<'de> for ConcurrencyConfig
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for ConcurrencyConfig
impl RefUnwindSafe for ConcurrencyConfig
impl Send for ConcurrencyConfig
impl Sync for ConcurrencyConfig
impl Unpin for ConcurrencyConfig
impl UnsafeUnpin for ConcurrencyConfig
impl UnwindSafe for ConcurrencyConfig
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> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request