Struct RateLimit 

pub struct RateLimit { /* private fields */ }

The sharded counters, and the process-random hash that decides which bucket an actor lands in.

Implementations

impl RateLimit

pub fn new(quota: Quota) -> RateLimit

pub fn quota(&self) -> Quota

pub fn admit(&self, actor: &str, now_ms: i64) -> bool

Charge one event to this actor, and say whether it is allowed.

now_ms is passed in rather than read, for the reason Proposal::at is: the merge point is the one place time enters, and it enters from the clock the process was configured with (§3.7, F11). A quota that read the wall clock itself would be a second, ambient one.