risingwave_stream::executor::backfill::utils

Function create_limiter

source
pub fn create_limiter(
    rate_limit: usize,
) -> Option<RateLimiter<NotKeyed, InMemoryState, MonotonicClock, NoOpMiddleware<Instant>>>