Struct Admission 

pub struct Admission {
    cpu: Arc<Semaphore>,
    mem: Option<Arc<Semaphore>>,
    queued: AtomicUsize,
    in_flight: AtomicUsize,
    rejected_overload: AtomicU64,
    rejected_queue_full: AtomicU64,
    rejected_shed: AtomicU64,
    resident_bytes: AtomicU64,
    cfg: AdmissionCfg,
}

Shared admission state (one per process, in AppState).

Fields

cpu: Arc<Semaphore>

mem: Option<Arc<Semaphore>>

None when the memory gate is disabled (mem_budget_bytes == 0).

queued: AtomicUsize

in_flight: AtomicUsize

rejected_overload: AtomicU64

rejected_queue_full: AtomicU64

rejected_shed: AtomicU64

resident_bytes: AtomicU64

Resident set size sampled by the background loop (bytes). Tests write this directly; production writes come from spawn_rss_sampler.

cfg: AdmissionCfg

Implementations

impl Admission

pub fn new(cfg: AdmissionCfg) -> Self

pub async fn acquire( self: &Arc<Self>, reserve_bytes: u64, ) -> Result<AdmissionGuard, ApiError>

Admit one parse job that will buffer up to reserve_bytes of upload.

Multipart rarely declares a length up front, so callers reserve the configured max file size — a conservative reservation that guarantees the byte bound holds (tighter packing is a follow-up once the actual size is known post-extract).

pub fn resident_bytes(&self) -> u64

Current sampled resident set size in bytes (0 = unknown/not sampled).

pub fn is_shedding(&self) -> bool

True when the RSS breaker would currently shed new work (readiness).

pub fn metrics_text(&self) -> String

Prometheus text exposition of the admission gauges/counters.

pub fn set_resident_bytes(&self, bytes: u64)

Test/simulation hook: set the sampled RSS directly.

Trait Implementations

impl Debug for Admission

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

Formats the value using the given formatter.