Struct OpcodeRateLimiter 

pub struct OpcodeRateLimiter { /* private fields */ }

A sliding-window outbound limiter over OpcodeRateLimits.

Mirrors Chia’s algorithm: per-period per-opcode count and cumulative size, plus an aggregate budget for everything that is not a transaction message.

Implementations

impl OpcodeRateLimiter

pub fn new( reset_seconds: u64, limit_factor: f64, limits: OpcodeRateLimits, ) -> Self

A limiter over limits, resetting its window every reset_seconds.

limit_factor scales every budget, so a peer can be given a fraction of the nominal allowance (Chia’s clients default to 0.6).

pub fn allow(&mut self, message: &DigMessage) -> bool

Whether message may be sent now, charging it against the budget when it may.

A refused message is NOT charged, so a caller that backs off and retries is not permanently penalised for having asked early.

Prefer Self::admit where the caller intends to retry: true/false cannot say whether waiting could ever help.

pub fn admit(&mut self, message: &DigMessage) -> Admission

Whether message may be sent now — and, when it may not, whether waiting could help.

The distinction is what keeps a caller from spinning forever: a frequency or cumulative budget clears on the next window roll, but a message larger than the per-message cap (or than a whole window’s budget) is refused identically in every window that will ever exist. Only Admission::Deferred is worth retrying.

Trait Implementations

impl Clone for OpcodeRateLimiter

fn clone(&self) -> OpcodeRateLimiter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OpcodeRateLimiter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.