Struct EdgePolicy 

#[non_exhaustive]
pub struct EdgePolicy {
    pub caps: QueueCaps,
    pub admission: AdmissionPolicy,
    pub over_budget: OverBudgetAction,
}

Per-edge policy bundle.

caps → soft/hard watermarks; admission → behavior between soft/hard; over_budget → action when capacity/budget constraints are breached.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

caps: QueueCaps

Capacity and watermarks.

admission: AdmissionPolicy

Admission behavior between soft and hard thresholds.

over_budget: OverBudgetAction

Action to take on over-budget scenarios at this edge.

Implementations

impl EdgePolicy

pub const fn new( caps: QueueCaps, admission: AdmissionPolicy, over_budget: OverBudgetAction, ) -> Self

Construct a new EdgePolicy.

pub const fn caps(&self) -> &QueueCaps

Borrow caps.

pub const fn admission(&self) -> &AdmissionPolicy

Borrow admission policy.

pub const fn over_budget(&self) -> &OverBudgetAction

Borrow over-budget action.

pub fn watermark(&self, items: usize, bytes: usize) -> WatermarkState

Compute a watermark state from occupancy stats.

pub fn decide( &self, items: usize, bytes: usize, item_bytes: usize, _deadline: Option<DeadlineNs>, _qos: QoSClass, ) -> AdmissionDecision

Apply admission logic based on header hints (deadline/qos) and occupancy.

Behaviour

• BelowSoft => Admit.
• BetweenSoftAndHard:
  • DeadlineAndQoSAware => consult deadline/qos to decide (TODO: full impl).
  • DropNewest => DropNewest.
  • DropOldest => Evict(1).
  • Block => Block.
• AtOrAboveHard:
  • If the single incoming item cannot fit under the hard cap (even when the queue is empty), the item is Rejected immediately.
  • Otherwise:
    • DropNewest => DropNewest.
    • DropOldest => EvictUntilBelowHard.
    • DeadlineAndQoSAware => conservative default Reject (or consult deadline/qos if implemented).
    • Block => Block.

Warning

QoS-aware behaviour is not yet implemented. The DeadlineAndQoSAware branch currently uses conservative defaults:

• between soft/hard it defaults to Admit, and
• at-or-above-hard it defaults to Reject.

Implementors should update this method to use deadline and QoS hints when the scheduler rules are available.

Trait Implementations

impl Clone for EdgePolicy

fn clone(&self) -> EdgePolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EdgePolicy

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

Formats the value using the given formatter.

impl PartialEq for EdgePolicy

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for EdgePolicy

impl Eq for EdgePolicy

impl StructuralPartialEq for EdgePolicy