Struct LocalLimits 

pub struct LocalLimits { /* private fields */ }

Limits shared by every shard of one process.

Implementations

impl LocalLimits

pub fn new() -> Self

pub fn max_in_use(&self, name: &str) -> u32

The most permits ever held at once (the simulator’s checker).

Trait Implementations

impl Debug for LocalLimits

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

Formats the value using the given formatter.

impl Default for LocalLimits

fn default() -> LocalLimits

Returns the “default value” for a type.

impl LimitBackend for LocalLimits

fn define(&self, name: &str, spec: LimitSpec)

fn ticket(&self) -> u64

A new ticket for one attempt’s permit.

fn acquire_in( &self, name: &str, ticket: u64, priority: &Priority, now_ms: u64, waker: Option<&Waker>, ) -> Acquire

Asks for the permit of ticket, queued at priority the first time it is asked for. Idempotent: asking again for a granted ticket answers Granted.

fn release(&self, name: &str, ticket: u64)

Returns a granted permit, or withdraws a queued ticket.

fn in_use(&self, name: &str) -> u32

Permits currently held (for checks and metrics).

fn waiting(&self, name: &str) -> usize

Steps waiting for a permit here, where the backend knows (metrics).

fn list(&self) -> Vec<(String, LimitSpec)>

The limits defined here, by name, where the backend knows (fusee limits, the UI).

fn acquire( &self, name: &str, ticket: u64, now_ms: u64, waker: Option<&Waker>, ) -> Acquire

acquire_in at the default priority.