Method new

src/adapter/src/statement_logging.rs:390–398

Create a new throttling state.

(now: &NowFn)

impl ThrottlingState {
    /// Create a new throttling state.
    pub fn new(now: &NowFn) -> Self {
        Self {
            inner: Mutex::new(ThrottlingStateInner {
                tokens: 0,
                last_logged_ts_seconds: now() / 1000,
            }),
            throttled_count: std::sync::atomic::AtomicUsize::new(0),
        }
    }

    /// Check if we need to drop a statement due to throttling, and update the number of available
    /// tokens appropriately.