Struct object_store::throttle::ThrottleConfig
source · pub struct ThrottleConfig {
pub wait_delete_per_call: Duration,
pub wait_get_per_byte: Duration,
pub wait_get_per_call: Duration,
pub wait_list_per_call: Duration,
pub wait_list_per_entry: Duration,
pub wait_list_with_delimiter_per_call: Duration,
pub wait_list_with_delimiter_per_entry: Duration,
pub wait_put_per_call: Duration,
}
Expand description
Configuration settings for throttled store
Fields§
§wait_delete_per_call: Duration
Sleep duration for every call to delete
.
Sleeping is done before the underlying store is called and independently of the success of the operation.
wait_get_per_byte: Duration
Sleep duration for every byte received during get
.
Sleeping is performed after the underlying store returned and only for successful gets. The
sleep duration is additive to wait_get_per_call
.
Note that the per-byte sleep only happens as the user consumes the output bytes. Should there be an intermediate failure (i.e. after partly consuming the output bytes), the resulting sleep time will be partial as well.
wait_get_per_call: Duration
Sleep duration for every call to get
.
Sleeping is done before the underlying store is called and independently of the success of
the operation. The sleep duration is additive to
wait_get_per_byte
.
wait_list_per_call: Duration
Sleep duration for every call to list
.
Sleeping is done before the underlying store is called and independently of the success of
the operation. The sleep duration is additive to
wait_list_per_entry
.
wait_list_per_entry: Duration
Sleep duration for every entry received during list
.
Sleeping is performed after the underlying store returned and only for successful lists.
The sleep duration is additive to wait_list_per_call
.
Note that the per-entry sleep only happens as the user consumes the output entries. Should there be an intermediate failure (i.e. after partly consuming the output entries), the resulting sleep time will be partial as well.
wait_list_with_delimiter_per_call: Duration
Sleep duration for every call to
list_with_delimiter
.
Sleeping is done before the underlying store is called and independently of the success of
the operation. The sleep duration is additive to
wait_list_with_delimiter_per_entry
.
wait_list_with_delimiter_per_entry: Duration
Sleep duration for every entry received during
list_with_delimiter
.
Sleeping is performed after the underlying store returned and only for successful gets. The
sleep duration is additive to
wait_list_with_delimiter_per_call
.
wait_put_per_call: Duration
Sleep duration for every call to put
.
Sleeping is done before the underlying store is called and independently of the success of the operation.
Trait Implementations§
source§impl Clone for ThrottleConfig
impl Clone for ThrottleConfig
source§fn clone(&self) -> ThrottleConfig
fn clone(&self) -> ThrottleConfig
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for ThrottleConfig
impl Debug for ThrottleConfig
source§impl Default for ThrottleConfig
impl Default for ThrottleConfig
source§fn default() -> ThrottleConfig
fn default() -> ThrottleConfig
impl Copy for ThrottleConfig
Auto Trait Implementations§
impl Freeze for ThrottleConfig
impl RefUnwindSafe for ThrottleConfig
impl Send for ThrottleConfig
impl Sync for ThrottleConfig
impl Unpin for ThrottleConfig
impl UnwindSafe for ThrottleConfig
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
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)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> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more