Struct ReplicationPacket 

pub struct ReplicationPacket {
    pub wire_version: ReplicationWireVersion,
    pub changeset_id: ChangesetId,
    pub sbn: u8,
    pub esi: u32,
    pub k_source: u32,
    pub r_repair: u32,
    pub symbol_size_t: u16,
    pub seed: u64,
    pub payload_xxh3: u64,
    pub auth_tag: Option<[u8; 16]>,
    pub symbol_data: Vec<u8>,
}

Replication packet: big-endian header + little-endian symbol payload.

Fields

wire_version: ReplicationWireVersion

Packet framing format.

changeset_id: ChangesetId

16-byte changeset identifier for multiplexing.

sbn: u8

Source block number (MUST be 0 in V1).

esi: u32

Encoding Symbol ID (ISI).

k_source: u32

Number of source symbols.

r_repair: u32

Number of planned repair symbols for this stream configuration.

symbol_size_t: u16

Symbol size T encoded on wire.

seed: u64

Deterministic seed for the object’s symbol schedule.

payload_xxh3: u64

Integrity hash over symbol_data.

auth_tag: Option<[u8; 16]>

Optional authenticated tag for security mode.

symbol_data: Vec<u8>

Symbol data (T bytes).

Implementations

impl ReplicationPacket

pub fn new_v2(header: ReplicationPacketV2Header, symbol_data: Vec<u8>) -> Self

Create a versioned fixed-header packet and compute payload integrity hash.

pub fn compute_payload_xxh3(symbol_data: &[u8]) -> u64

Compute packet payload hash.

pub fn attach_auth_tag(&mut self, auth_key: &[u8; 32])

Attach an auth tag for authenticated transport mode.

pub fn verify_integrity(&self, auth_key: Option<&[u8; 32]>) -> bool

Verify payload hash and optional auth tag.

pub fn validate_symbol_size(symbol_size: usize) -> Result<()>

Validate the symbol size against the hard wire limit.

Errors

Returns error if symbol size exceeds MAX_REPLICATION_SYMBOL_SIZE.

pub fn to_bytes(&self) -> Result<Vec<u8>>

Encode to wire format: 24-byte big-endian header + symbol data.

Errors

Returns error if ESI doesn’t fit in 24 bits or symbol exceeds wire limit.

pub fn from_bytes(buf: &[u8]) -> Result<Self>

Decode from wire format.

Errors

Returns error if buffer is too short.

pub fn wire_size(&self) -> usize

Total packet size on the wire.

pub fn is_source_symbol(&self) -> bool

Whether this packet carries a source symbol (systematic).

Trait Implementations

impl Clone for ReplicationPacket

fn clone(&self) -> ReplicationPacket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationPacket

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

Formats the value using the given formatter.

impl PartialEq for ReplicationPacket

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

impl StructuralPartialEq for ReplicationPacket