Struct FipsEndpointDirectPacketRun 

pub struct FipsEndpointDirectPacketRun { /* private fields */ }

Consecutive direct endpoint packets from one authenticated FIPS source.

Unlike FipsEndpointDirectSourceRun, this can preserve an opened EndpointDataBulk buffer and expose packet slices by range. That is the canonical direct PM2 endpoint payload contract for high-throughput embedders: FIPS owns authentication and ordering, while the embedder can still apply live routing policy before borrowing packet bytes for TUN writes.

Implementations

impl FipsEndpointDirectPacketRun

pub fn meta(&self) -> &FipsEndpointDirectPacketRunMeta

Authenticated source/session facts for this packet run.

pub fn source_peer(&self) -> &PeerIdentity

Authenticated FIPS peer that originated every packet in this run.

pub fn source_node_addr(&self) -> &NodeAddr

FIPS node address that originated every packet in this run.

pub fn source_npub(&self) -> String

Source Nostr public key as human-facing bech32 text.

pub fn previous_hop_node_addr(&self) -> &NodeAddr

Authenticated previous hop for this established FSP receive run.

pub fn is_direct_path(&self) -> bool

Whether FIPS received the run directly from the source node.

pub fn received_k_bit(&self) -> bool

Whether the established FSP packet carried the key-epoch bit.

pub fn enqueued_at_ms(&self) -> u64

Unix-millisecond time when FIPS handed this run to the direct sink.

pub fn len(&self) -> usize

Number of endpoint packets in the run.

pub fn is_empty(&self) -> bool

Whether the run contains no packets.

pub fn packet_bytes(&self) -> usize

Sum of endpoint packet bytes, excluding bulk length metadata.

pub fn packet_slice(&self, index: usize) -> Option<&[u8]>

Borrow one packet by index.

pub fn packet_slice_mut(&mut self, index: usize) -> Option<&mut [u8]>

Mutably borrow one packet by index.

pub fn packet_slices(&self) -> FipsEndpointDirectPacketSlices<'_>

Borrow packet bytes without materializing per-packet buffers.

pub fn partition_by_packet_lane<F>( self, lane_count: usize, lane_for_packet: F, ) -> Vec<(usize, Self)>

where F: FnMut(&[u8]) -> usize,

Partition this run into packet-lane groups without copying packet bytes.

The caller chooses a lane from immutable endpoint packet bytes. FIPS keeps authentication/session metadata on every child run and shares the opened endpoint payload buffer across lane runs.

pub fn retain_packets<F>(&mut self, keep: F)

where F: FnMut(usize, &[u8]) -> bool,

Keep only packets accepted by the caller while preserving backing storage.

The predicate receives the original packet index and immutable bytes. This keeps routing/admission policy outside FIPS while allowing embedders to remove rejected ranges before a TUN writer borrows or mutates the run.

pub fn for_each_packet_mut<F>(&mut self, visit: F)

where F: FnMut(&mut [u8]),

Visit each packet as mutable bytes while the run owner is borrowed.

pub fn into_source_run(self) -> FipsEndpointDirectSourceRun

Materialize this run into the older owned-packet source-run contract.

pub fn into_packets(self) -> Vec<PacketBuffer>

Materialize this run into owned packet buffers.

Trait Implementations

impl Clone for FipsEndpointDirectPacketRun

fn clone(&self) -> FipsEndpointDirectPacketRun

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FipsEndpointDirectPacketRun

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

Formats the value using the given formatter.

impl Eq for FipsEndpointDirectPacketRun

impl PartialEq for FipsEndpointDirectPacketRun

fn eq(&self, other: &FipsEndpointDirectPacketRun) -> 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 StructuralPartialEq for FipsEndpointDirectPacketRun