Struct IngressEdgeLink 

pub struct IngressEdgeLink<'src, OutP, S, const OUT: usize>
where
    OutP: Payload,
    S: Source<OutP, OUT> + ?Sized,
{ /* private fields */ }

A tiny link wrapper for the synthetic ingress edge.

Wraps a borrowing SourceIngressEdge<'s, OutP, S, OUT> so the graph can expose ingress pressure straight from the concrete source implementation.

Implementations

impl<'src, OutP, S, const OUT: usize> IngressEdgeLink<'src, OutP, S, OUT>

where OutP: Payload, S: Source<OutP, OUT> + ?Sized,

pub const fn from_source( src: &'src S, id: EdgeIndex, upstream: PortId, downstream: PortId, policy: EdgePolicy, name: Option<&'static str>, ) -> Self

Construct from a borrowed source reference.

pub fn descriptor(&self) -> EdgeDescriptor

Edge descriptor.

pub fn policy(&self) -> EdgePolicy

Policy accessor.

pub fn inner(&self) -> &SourceIngressEdge<'src, OutP, S, OUT>

Borrow the inner borrowing edge.

Trait Implementations

impl<'s, OutP, S, const OUT: usize> Edge for IngressEdgeLink<'s, OutP, S, OUT>

where OutP: Payload, S: Source<OutP, OUT> + ?Sized,

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 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 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_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.