API
#rateToken-bucket rate limiter (single task; S6 — no `&mut` across `xu`). mut lim := rate.new(100, 100) // 100 events/s, burst 100 if lim.allow {... } For per-peer limits keep one Limiter per peer on the coordinator task.
struct Limiterpub struct Limiter {
}Token-bucket rate limiter (single task; S6 — no `&mut` across `xu`). mut lim := rate.new(100, 100) // 100 events/s, burst 100 if lim.allow {... } For per-peer limits keep one Limiter per peer on the coordinator task.
none
newpub fn new(events_per_sec int, burst int) Limiternew(events_per_sec, burst). burst must be >= 1.
events_per_sec intburst intLimiter — a value of this type
(&mut Limiter) allowpub fn (l &mut Limiter) allow() boolallow consumes one token if available.
l &mut Limiterbool — true or false
(&mut Limiter) allow_npub fn (l &mut Limiter) allow_n(n int) boolallow_n consumes n tokens or none (all-or-nothing).
l &mut Limitern intbool — true or false
(Limiter) availablepub fn (l Limiter) available() intCall `available` on `Limiter`.
l Limiterint — a value of this type
(Limiter) sleep_for_hintpub fn (l Limiter) sleep_for_hint() intsleep_for_hint returns a rough ns until one token exists (0 if ready).
l Limiterint — a value of this type