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
sourceimpl Clone for ThrottleConfig
impl Clone for ThrottleConfig
sourcefn clone(&self) -> ThrottleConfig
fn clone(&self) -> ThrottleConfig
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Debug for ThrottleConfig
impl Debug for ThrottleConfig
sourceimpl Default for ThrottleConfig
impl Default for ThrottleConfig
sourcefn default() -> ThrottleConfig
fn default() -> ThrottleConfig
Returns the “default value” for a type. Read more
impl Copy for ThrottleConfig
Auto Trait Implementations
impl RefUnwindSafe for ThrottleConfig
impl Send for ThrottleConfig
impl Sync for ThrottleConfig
impl Unpin for ThrottleConfig
impl UnwindSafe for ThrottleConfig
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for Twhere
V: MultiLane<T>,
impl<V, T> VZip<V> for Twhere
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more