Struct TaskSchedulerQuota 

pub struct TaskSchedulerQuota {
    pub identity: ExecutionIdentityV1,
    pub max_active: usize,
}

Immutable capacity quota carried by one scheduler admission request.

The quota is deliberately a descriptor rather than a second queue or semaphore. The scheduler actor remains the only authority that decides whether work owns a global slot or a quota-only reservation; it additionally refuses to admit more than max_active requests for this digest-only capacity identity at once.

Fields

identity: ExecutionIdentityV1

Digest-only identity of the run/host/provider scope consuming capacity.

max_active: usize

Maximum reservations this capacity identity may hold concurrently.

Implementations

impl TaskSchedulerQuota

pub fn new( identity: ExecutionIdentityV1, max_active: usize, ) -> Result<Self, TaskSchedulerError>

Build and validate a capacity quota descriptor.

pub fn validate(&self) -> Result<(), TaskSchedulerError>

Validate a quota received from a host or a deserialized boundary.

pub fn for_scope( scope: &str, max_active: usize, ) -> Result<Self, TaskSchedulerError>

Derive a digest-only quota identity from a bounded host/run scope.

The scope is used only during derivation and is never retained or emitted by scheduler diagnostics. Callers should use a stable run or host identifier, not a prompt or tool payload.

pub fn identity(&self) -> &ExecutionIdentityV1

Return the immutable owner identity.

Trait Implementations

impl Clone for TaskSchedulerQuota

fn clone(&self) -> TaskSchedulerQuota

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskSchedulerQuota

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskSchedulerQuota

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for TaskSchedulerQuota

impl PartialEq for TaskSchedulerQuota

fn eq(&self, other: &TaskSchedulerQuota) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for TaskSchedulerQuota

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TaskSchedulerQuota