Struct RemoteLimits 

pub struct RemoteLimits { /* private fields */ }

The worker’s LimitBackend in server mode.

Implementations

impl RemoteLimits

pub fn new(wire: Arc<dyn LimitWire>, worker_id: u64) -> Arc<Self>

pub fn answered(&self, ticket: u64, granted: bool, retry_at: u64)

The server answered an acquire.

Trait Implementations

impl Debug for RemoteLimits

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

Formats the value using the given formatter.

impl LimitBackend for RemoteLimits

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 acquire( &self, name: &str, ticket: u64, now_ms: u64, waker: Option<&Waker>, ) -> Acquire

acquire_in at the default priority.

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

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