Method drain

nodedb/src/control/security/metering/counter.rs:82–109

Drain all accumulated counters for flushing to the store. Returns aggregated events and resets counters to zero.

(&self)

    /// Drain all accumulated counters for flushing to the store.
    /// Returns aggregated events and resets counters to zero.
    pub fn drain(&self) -> Vec<UsageEvent> {
        let now = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .unwrap_or_default()
            .as_secs();

        let buckets = self.buckets.read().unwrap_or_else(|p| p.into_inner());
        let mut events = Vec::with_capacity(buckets.len());

        for (key, counter) in buckets.iter() {
            let tokens = counter.swap(0, Ordering::Relaxed);
            if tokens > 0 {
                events.push(UsageEvent {
                    auth_user_id: key.auth_user_id.clone(),
                    org_id: key.org_id.clone(),
                    tenant_id: key.tenant_id,
                    collection: key.collection.clone(),
                    engine: key.engine.clone(),
                    operation: key.operation.clone(),
                    tokens,
                    timestamp_secs: now,
                });
            }
        }

        self.total_tokens.store(0, Ordering::Relaxed);
        events
    }

    /// Total tokens metered since last flush.
    pub fn total_tokens(&self) -> u64 {