Struct DemoRuntime 

pub struct DemoRuntime { /* private fields */ }

Implementations

impl DemoRuntime

pub fn try_acquire_global_run( &self, ) -> Result<OwnedSemaphorePermit, TryAcquireError>

pub fn try_acquire_global_sse( &self, ) -> Result<OwnedSemaphorePermit, TryAcquireError>

pub fn try_acquire_ordinary_request( &self, ) -> Result<OwnedSemaphorePermit, TryAcquireError>

pub async fn lock_start_admission(&self) -> OwnedMutexGuard<()>

Serializes the short admission phase that checks global row capacity and persists a prepared run. Without this guard, several simultaneous starts could all observe one remaining row slot before any of them inserted, exceeding the fixed global Demo cap.

pub async fn try_acquire_visitor_run( &self, token_hash: &str, limit: u32, ) -> Result<OwnedSemaphorePermit, TryAcquireError>

pub async fn try_acquire_visitor_sse( &self, token_hash: &str, limit: u32, ) -> Result<OwnedSemaphorePermit, TryAcquireError>

pub async fn reserve_accepted_start( &self, token_hash: &str, client_ip: &str, now: DateTime<Utc>, policy: DemoPolicy, ) -> Result<DemoAcceptedStart, DemoQuotaExceeded>

Atomically reserves one accepted-start slot in both the visitor-token and client-IP windows. A caller that fails before scheduling the run must release the returned handle; a successfully scheduled run leaves it recorded until the fixed window expires.

pub async fn release_accepted_start(&self, accepted: DemoAcceptedStart)

pub async fn cleanup(&self, now: DateTime<Utc>, policy: DemoPolicy)

Reclaims expired quota entries and inactive per-visitor semaphores during the periodic Demo cleanup pass, including tokens that never make another request.

Trait Implementations

impl Clone for DemoRuntime

fn clone(&self) -> DemoRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.