Skip to main content

ThrottleError

Enum ThrottleError 

Source
#[non_exhaustive]
pub enum ThrottleError { CostExceedsCapacity { cost: u32, capacity: u32, }, CircuitOpen { retry_after: Duration, }, QueueFull, DeadlineExceeded, }
Available on crate feature std only.
Expand description

An acquisition that cannot complete.

The enum is #[non_exhaustive]: later phases introduce new failure modes (deadlines, a tripped circuit breaker, a closed limiter), so a match on it must include a wildcard arm.

§Examples

use throttle_net::{Throttle, ThrottleError};

// Capacity is 5; asking for 9 can never be satisfied.
let throttle = Throttle::per_second(5);
let err = throttle.acquire_with_cost(9).await.unwrap_err();
assert!(matches!(err, ThrottleError::CostExceedsCapacity { cost: 9, capacity: 5 }));

Variants (Non-exhaustive)§

This enum is marked as non-exhaustive
Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.
§

CostExceedsCapacity

The requested cost is larger than the limiter’s capacity, so the bucket can never hold enough tokens to grant it. Reduce the cost or raise the limiter’s capacity. This is a configuration mismatch, not a transient condition, so it is not retryable.

Fields

§cost: u32

The number of tokens the caller asked for.

§capacity: u32

The limiter’s maximum capacity, which cost exceeded.

§

CircuitOpen

A circuit breaker is open and shed this request without touching the wrapped limiter. The breaker is failing fast to give the downstream time to recover; retry once it has had a chance to close again. This is retryable, after the suggested wait.

Fields

§retry_after: Duration

How long until the breaker is expected to allow a trial request (move to half-open). Duration::ZERO means it may already be admitting a trial.

§

QueueFull

A bounded queue was full and its overflow policy rejected this request. Transient — capacity may free up — so it is retryable.

§

DeadlineExceeded

A queued request’s deadline passed before it could be served. Not retryable as-is: the deadline is in the past.

Trait Implementations§

Source§

impl Clone for ThrottleError

Source§

fn clone(&self) -> ThrottleError

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Copy for ThrottleError

Source§

impl Debug for ThrottleError

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Display for ThrottleError

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Eq for ThrottleError

Source§

impl Error for ThrottleError

1.30.0 · Source§

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

👎Deprecated since 1.42.0:

use the Display impl or to_string()

1.0.0 · Source§

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

Source§

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type-based access to context intended for error reports. Read more
Source§

impl ForgeError for ThrottleError

Source§

fn kind(&self) -> &'static str

Returns the kind of error, typically matching the enum variant
Source§

fn caption(&self) -> &'static str

Returns a human-readable caption for the error
Source§

fn is_retryable(&self) -> bool

Returns true if the operation can be retried
Source§

fn is_fatal(&self) -> bool

Returns true if the error is fatal and should terminate the program
Source§

fn status_code(&self) -> u16

Returns an appropriate HTTP status code for the error
Source§

fn exit_code(&self) -> i32

Returns an appropriate process exit code for the error
Source§

fn user_message(&self) -> String

Returns a user-facing message that can be shown to end users
Source§

fn dev_message(&self) -> String

Returns a detailed technical message for developers/logs
Source§

fn backtrace(&self) -> Option<&Backtrace>

Returns a backtrace if available
Source§

fn register(&self)

Registers the error with the central error registry
Source§

impl PartialEq for ThrottleError

Source§

fn eq(&self, other: &ThrottleError) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 (const: unstable) · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl StructuralPartialEq for ThrottleError

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> ForgeErrorRecovery for T
where T: ForgeError,

Source§

fn create_retry_policy(&self, max_retries: usize) -> RetryPolicy

Create a retry policy optimized for this error type
Source§

fn retry<F, T, E>(&self, max_retries: usize, operation: F) -> Result<T, E>
where F: FnMut() -> Result<T, E>, E: ForgeError,

Execute a fallible operation with retries if this error type is retryable
Source§

fn create_circuit_breaker(&self, name: impl Into<String>) -> CircuitBreaker

Create a circuit breaker for operations that might result in this error type
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T> ToString for T
where T: Display + ?Sized,

Source§

fn to_string(&self) -> String

Converts the given value to a String. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<E> WithErrorCode<E> for E

Source§

fn with_code(self, code: impl Into<String>) -> CodedError<E>

Attach an error code to an error
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more