Struct HierarchicalDeficitRoundRobin 

pub struct HierarchicalDeficitRoundRobin<VmId, CapabilityId> { /* private fields */ }

Process-level VM rotation containing a second capability rotation per VM.

The scheduler is intentionally serial: callers select one bounded turn, perform no more than its allowance, then report actual use. This makes the selection order reproducible in tests and keeps requeueing atomic.

Implementations

impl<VmId, CapabilityId> HierarchicalDeficitRoundRobin<VmId, CapabilityId>

where VmId: Clone + Ord, CapabilityId: Clone + Ord,

pub fn new(config: FairnessConfig) -> Result<Self, FairnessError>

pub fn new_with_metrics( config: FairnessConfig, metrics: RuntimeMetrics, ) -> Result<Self, FairnessError>

pub fn config(&self) -> FairnessConfig

pub fn mark_ready( &mut self, vm_id: VmId, capability_id: CapabilityId, ) -> Result<MembershipUpdate, FairnessError>

Insert one ready membership edge. Repeated marks never add queue entries.

pub fn clear_ready( &mut self, vm_id: &VmId, capability_id: &CapabilityId, ) -> bool

Remove queued readiness without discarding retained, capped deficit.

pub fn select_next( &mut self, ) -> Result<Option<FairSelection<VmId, CapabilityId>>, FairnessError>

Choose the next VM and capability in activation order.

pub fn complete( &mut self, selection: &FairSelection<VmId, CapabilityId>, used: FairBudget, still_ready: bool, ) -> Result<(), FairnessError>

Charge actual work and atomically requeue a source that remains ready.

pub fn remove_capability( &mut self, vm_id: &VmId, capability_id: &CapabilityId, ) -> Result<bool, FairnessError>

pub fn clear_vm_ready(&mut self, vm_id: &VmId) -> bool

Revoke every queued/rearmed turn for a VM without disturbing a turn already issued to native work. VM retirement uses this before attempting removal so no queued capability can run while issued work settles.

pub fn remove_vm(&mut self, vm_id: &VmId) -> Result<bool, FairnessError>

pub fn snapshot( &self, vm_id: &VmId, capability_id: &CapabilityId, ) -> Option<FairnessSnapshot>

pub fn ready_vm_count(&self) -> usize

pub fn ready_capability_count(&self, vm_id: &VmId) -> usize

Trait Implementations

impl<VmId: Debug, CapabilityId: Debug> Debug for HierarchicalDeficitRoundRobin<VmId, CapabilityId>

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

Formats the value using the given formatter.