Struct EdgeLink 

#[non_exhaustive]
pub struct EdgeLink<Q>
where
    Q: Edge,
{ /* private fields */ }

A lightweight descriptor that links to the concrete queue instance backing a graph edge, along with its routing and policy metadata.

Unlike a pure descriptor, EdgeLink owns the queue implementation. This keeps it zero-alloc and allows direct, policy-aware operations on the buffer.

• Q: concrete queue type implementing Edge

Implementations

impl<Q> EdgeLink<Q>

where Q: Edge,

pub fn new( queue: Q, id: EdgeIndex, upstream_port: PortId, downstream_port: PortId, policy: EdgePolicy, name: Option<&'static str>, ) -> Self

Construct a new EdgeLink that owns the given queue and records its metadata.

pub fn queue(&self) -> &Q

Get a reference to the inner queue.

pub fn queue_mut(&mut self) -> &mut Q

Get a mutable reference to the inner queue.

pub fn id(&self) -> &EdgeIndex

Get the unique identifier of this edge.

pub fn upstream_port(&self) -> &PortId

Get the upstream output port index.

pub fn downstream_port(&self) -> &PortId

Get the downstream input port index.

pub fn policy(&self) -> &EdgePolicy

Get the edge policy applied to this queue.

pub fn name(&self) -> Option<&'static str>

Get the optional static name of this queue link.

pub fn descriptor(&self) -> EdgeDescriptor

Return the EdgeDescriptor for this EdgeLink.

Trait Implementations

impl<Q> Debug for EdgeLink<Q>

where Q: Edge + Debug,

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

Formats the value using the given formatter.

impl<Q> Edge for EdgeLink<Q>

where Q: Edge,

fn try_push<H: HeaderStore>( &mut self, token: MessageToken, policy: &EdgePolicy, headers: &H, ) -> EnqueueResult

Attempt to push a token onto the queue using the given edge policy.

fn try_pop<H: HeaderStore>( &mut self, headers: &H, ) -> Result<MessageToken, QueueError>

Attempt to pop the front token from the queue.

fn occupancy(&self, policy: &EdgePolicy) -> EdgeOccupancy

Return a snapshot of occupancy used for telemetry and admission.

fn is_empty(&self) -> bool

Return true if the queue is empty.

fn try_peek(&self) -> Result<MessageToken, QueueError>

Peek at the front token without removing it.

fn try_peek_at(&self, index: usize) -> Result<MessageToken, QueueError>

Peek at the token at logical position index from the front.

fn try_pop_batch<H: HeaderStore>( &mut self, policy: &BatchingPolicy, headers: &H, ) -> Result<BatchView<'_, MessageToken>, QueueError>

Pop a batch of tokens according to the provided batching policy.

fn peek_header<'h, H: HeaderStore>( &self, headers: &'h H, ) -> Result<<H as HeaderStore>::HeaderGuard<'h>, QueueError>

Peek the front message header via HeaderStore (convenience).

fn get_admission_decision<H: HeaderStore>( &self, policy: &EdgePolicy, token: MessageToken, headers: &H, ) -> AdmissionDecision

Return an AdmissionDecision for the given token according to policy and the current occupancy snapshot.

fn get_admission_decision_from_message<P: Payload>( &self, policy: &EdgePolicy, message: &Message<P>, ) -> AdmissionDecision

Return an AdmissionDecision for the given token according to policy and the current occupancy snapshot.