Struct MonitoredRateLimiter 

pub struct MonitoredRateLimiter {
    pub(crate) inner: RateLimiter,
    pub(crate) metric: LabelGuardedUintGauge,
    pub(crate) rate_limit: AtomicU64,
}

A rate limiter that supports multiple rate limit policy, online policy switch and metrics support.

Fields

inner: RateLimiter

metric: LabelGuardedUintGauge

rate_limit: AtomicU64

Implementations

impl MonitoredRateLimiter

pub(crate) fn report(&self)

Report the rate limit policy to the metric if updated.

report is called automatically by each until call.

Methods from Deref<Target = RateLimiter>

pub fn update(&self, rate_limit: RateLimit) -> RateLimit

Update rate limit policy of the rate limiter.

Returns the old rate limit policy.

pub fn rate_limit(&self) -> RateLimit

pub fn check(&self, quota: u64) -> Check

pub async fn wait(&self, quota: u64)

pub async fn wait_chunk(&self, chunk: &DataChunk)

Trait Implementations

impl Deref for MonitoredRateLimiter

type Target = RateLimiter

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl RateLimiterTrait for MonitoredRateLimiter

fn rate_limit(&self) -> RateLimit

Return current throttle policy.

fn check(&self, quota: u64) -> Check

Check if the request with the given quota is supposed to be allowed at the moment.