pub enum QuotaError {
SubsCapExceeded {
have: u32,
cap: u32,
},
RestRateLimit {
remaining_ms: u64,
},
NotInWhitelist(String),
Inner(StationError),
}Expand description
Errors produced by ConsumerHandle operations.
Variants§
SubsCapExceeded
The requested subscribe batch would push the consumer over its cap. Nothing in the batch was subscribed (atomic-or-nothing).
RestRateLimit
The consumer’s REST token bucket is empty.
remaining_ms is an upper-bound estimate until the next refill.
NotInWhitelist(String)
A (exchange, kind, symbol) tuple in the subscribe set was rejected
by the consumer’s whitelist. Nothing in the batch was subscribed.
Inner(StationError)
An underlying station error (e.g. StreamNotSupported, IO).
Trait Implementations§
Source§impl Debug for QuotaError
impl Debug for QuotaError
Source§impl Display for QuotaError
impl Display for QuotaError
Source§impl Error for QuotaError
impl Error for QuotaError
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
Source§impl From<StationError> for QuotaError
impl From<StationError> for QuotaError
Source§fn from(source: StationError) -> Self
fn from(source: StationError) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl !RefUnwindSafe for QuotaError
impl !UnwindSafe for QuotaError
impl Freeze for QuotaError
impl Send for QuotaError
impl Sync for QuotaError
impl Unpin for QuotaError
impl UnsafeUnpin for QuotaError
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
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> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ToStringFallible for Twhere
T: Display,
impl<T> ToStringFallible for Twhere
T: Display,
Source§fn try_to_string(&self) -> Result<String, TryReserveError>
fn try_to_string(&self) -> Result<String, TryReserveError>
ToString::to_string, but without panic on OOM.