Struct Lane 

pub struct Lane {
    pub id: LaneId,
    pub name: String,
    pub budget: Budget,
    pub pending: u32,
    pub completed: u64,
    pub channels: BTreeSet<u64>,
    pub caps: BTreeSet<u128>,
    pub closed: bool,
    pub ready: VecDeque<u64>,
}

A lane’s state.

Fields

id: LaneId

Kernel-assigned identifier.

name: String

The name the caller chose.

budget: Budget

The lane’s own call and byte ceiling.

pending: u32

Calls issued by this lane that have not completed.

completed: u64

Completed calls.

channels: BTreeSet<u64>

Channels this lane is subscribed to.

caps: BTreeSet<u128>

Capabilities minted for this lane.

closed: bool

True once the lane has been destroyed; further calls are refused.

ready: VecDeque<u64>

Per-lane ready queue of job ids.

Implementations

impl Lane

pub fn new(id: LaneId, name: impl Into<String>, budget: Budget) -> Self

Create an open lane with its own budget.

pub fn attenuate(&mut self, budget: Budget) -> Result<()>

Attenuate a lane’s budget; refuses widening.

pub fn complete(&mut self)

Record a completed call against the lane.

pub fn destroy(&mut self)

Close the lane.

pub fn has_capacity(&self) -> bool

Whether the lane may issue another call under its budget.

Pending calls count: queueing a thousand calls before run() must not let a lane outspend its grant.

Trait Implementations

impl Clone for Lane

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Lane

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

Formats the value using the given formatter.