Struct GroupRateLimiter 

pub struct GroupRateLimiter { /* private fields */ }

Group-based rate limiter: multiple independent pools keyed by name.

Each group is an independent WeightRateLimiter with its own max/window. Requests are routed to the appropriate group by the connector.

Used by exchanges:

• Phemex: CONTRACT, SPOTORDER, OTHERS groups
• Upbit: market, account, order groups
• Kraken Futures: derivatives (500/10s), history (100/600s)

Implementations

impl GroupRateLimiter

pub fn new() -> Self

Create a new empty group rate limiter

pub fn add_group( &mut self, name: &'static str, max_weight: u32, window: Duration, )

Add a named rate limit group

Arguments

• name - Group name (must be 'static str, e.g. "public")
• max_weight - Maximum total weight for this group’s window
• window - Time window duration for this group

pub fn try_acquire(&mut self, group: &str, weight: u32) -> bool

Try to acquire weight from a specific group

Returns

• true if weight is within the group’s limit (or group is unknown)
• false if adding this weight would exceed the group’s limit

pub fn time_until_ready(&mut self, group: &str, weight: u32) -> Duration

Get wait time for a specific group

Returns

• Duration::ZERO if the group is unknown or request fits within limits
• Otherwise, the time to wait until enough weight capacity is available

pub fn update_from_server(&mut self, group: &str, used_weight: u32)

Update server-reported used weight for a specific group

Arguments

• group - Group name
• used_weight - Current used weight reported by server for this group

pub fn group_stats(&mut self, group: &str) -> Option<(u32, u32)>

Get (current_weight, max_weight) for a specific group

Returns None if the group does not exist.

pub fn all_stats(&mut self) -> Vec<(&str, u32, u32)>

Get stats for all groups as Vec of (name, current_weight, max_weight)

pub fn primary_stats(&mut self) -> (u32, u32)

Get primary group stats for backwards-compatible display

Returns (current_weight, max_weight) of an arbitrary group, or (0, 0) when no groups have been added.

Trait Implementations

impl Clone for GroupRateLimiter

fn clone(&self) -> GroupRateLimiter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GroupRateLimiter

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

Formats the value using the given formatter.

impl Default for GroupRateLimiter

fn default() -> Self

Returns the “default value” for a type.