Struct RefreshCoordinator 

pub struct RefreshCoordinator(/* private fields */);

Instance resource shared by all refresh requests. No global singleton or historical-JTI leak. The finite budget includes running requests and same-JTI waiters; saturation rejects promptly. It complements, never replaces, the product’s authoritative cross-instance database CAS.

Implementations

impl RefreshCoordinator

pub fn new(maximum: usize) -> Result<Self>

Creates a bounded instance resource.

Errors

Returns InvalidPolicy for zero or a limit beyond Tokio’s semaphore capacity.

pub fn close(&self)

Rejects new requests and wakes queued waiters. Already-started store transactions complete.

pub fn is_closed(&self) -> bool

Reports whether shutdown has started.

pub fn active_requests(&self) -> usize

Number of admitted running/queued requests, for resource diagnostics and deterministic tests.

pub fn tracked_ids(&self) -> usize

Number of live JTI lock entries. No raw identity is exposed to observation.

Trait Implementations

impl Clone for RefreshCoordinator

fn clone(&self) -> RefreshCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RefreshCoordinator

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

Formats the value using the given formatter.

impl Default for RefreshCoordinator

fn default() -> Self

Returns the “default value” for a type.