Struct PeerMessageCodec 

pub struct PeerMessageCodec { /* private fields */ }

Length-delimited message codec with optional CRC32 integrity checking.

Example

use ipfrs_network::message_codec::{PeerMessageCodec, CodecConfig};

let codec = PeerMessageCodec::new(CodecConfig::default());
let wire = codec.encode(b"hello").expect("encode");
let payload = codec.decode(&wire).expect("decode");
assert_eq!(payload, b"hello");

Implementations

impl PeerMessageCodec

pub fn new(config: CodecConfig) -> Self

Create a new codec with the given configuration.

pub fn encode(&self, payload: &[u8]) -> Result<Vec<u8>, CodecError>

Encode a payload into wire format.

Returns the complete frame: [4-byte length BE][payload][optional 4-byte CRC32].

Errors

Returns CodecError::MessageTooLarge if payload.len() exceeds config.max_message_size.

pub fn encode_with_metadata( &self, payload: &[u8], ) -> Result<EncodedMessage, CodecError>

Encode a payload and return an EncodedMessage with metadata.

pub fn decode(&self, data: &[u8]) -> Result<Vec<u8>, CodecError>

Decode a wire-format frame and return the payload bytes.

Errors

• CodecError::BufferTooSmall if data is shorter than the length prefix.
• CodecError::InvalidLength if the frame is truncated or the length prefix is inconsistent with the buffer size.
• CodecError::MessageTooLarge if the decoded length exceeds the configured maximum.
• CodecError::ChecksumMismatch if checksums are enabled and the stored checksum doesn’t match the computed one.

pub fn crc32(data: &[u8]) -> u32

Compute a CRC32 checksum (IEEE / ISO 3309) of the given data.

pub fn estimate_encoded_size(&self, payload_size: usize) -> usize

Estimate the total encoded size for a payload of the given length.

Returns 4 + payload_size + (4 if checksum enabled).

pub fn decode_length(&self, data: &[u8]) -> Result<usize, CodecError>

Peek at the length prefix without performing a full decode.

Returns the payload length encoded in the first 4 bytes.

Errors

• CodecError::BufferTooSmall if data has fewer than 4 bytes.
• CodecError::InvalidLength if the decoded length is zero but additional bytes suggest corruption (currently not enforced — zero-length payloads are valid).

pub fn stats(&self) -> CodecStats

Return cumulative codec statistics.

pub fn config(&self) -> &CodecConfig

Return a reference to the current configuration.

Trait Implementations

impl Debug for PeerMessageCodec

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

Formats the value using the given formatter.