Struct ModelGenerationAdmission 

pub struct ModelGenerationAdmission { /* private fields */ }

Shared admission gate derived from a typed provider concurrency contract.

Clones share the same semaphore. A permit is owned and releases capacity on every exit path, including future cancellation and task abortion.

Implementations

impl ModelGenerationAdmission

pub fn new(concurrency: ModelGenerationConcurrency) -> Self

pub fn with_scheduler_quota( self, scheduler: Arc<TaskScheduler>, quota: TaskSchedulerQuota, priority: TaskPriority, label: impl Into<String>, ) -> Result<Self, TaskSchedulerError>

Attach a provider/model quota to this gate without creating another queue. Each permit reserves the quota through the existing scheduler actor, while the local semaphore retains the client’s own contract.

pub fn with_model_generation_pool( self, scheduler: Arc<TaskScheduler>, pool: ModelGenerationPool, priority: TaskPriority, label: impl Into<String>, ) -> Result<Self, TaskSchedulerError>

Attach a provider pool descriptor and its shared scheduler quota.

The pool is configuration evidence only; live reservations continue to be owned by the existing scheduler actor and local semaphore.

pub fn concurrency(&self) -> ModelGenerationConcurrency

pub async fn pool_health( &self, ) -> Result<Option<ModelGenerationPoolHealthSnapshot>, TaskSchedulerError>

Return secret-free pool configuration and point-in-time health.

None means this admission was created for a custom client that did not publish a ModelGenerationPool.

pub async fn acquire( &self, cancellation: &CancellationToken, ) -> Result<ModelGenerationPermit, ModelGenerationAdmissionError>

Wait for active-generation capacity without applying an active generation deadline to the queue wait.

Trait Implementations

impl Clone for ModelGenerationAdmission

fn clone(&self) -> ModelGenerationAdmission

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ModelGenerationAdmission

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

Formats the value using the given formatter.

impl Default for ModelGenerationAdmission

fn default() -> Self

Returns the “default value” for a type.