Struct DataPacket 

pub struct DataPacket {
    pub packet_id: String,
    pub source_node_id: String,
    pub destination_node_id: Option<String>,
    pub data_type: DataType,
    pub direction: DataDirection,
    pub hop_count: u16,
    pub max_hops: u16,
    pub payload: Vec<u8>,
}

Data packet metadata for routing decisions

Fields

packet_id: String

Unique packet identifier

source_node_id: String

Node ID of the original sender

destination_node_id: Option<String>

Node ID of the intended final recipient (None = broadcast)

data_type: DataType

Type of data in this packet

direction: DataDirection

Direction of data flow

hop_count: u16

Hop count (incremented at each forward)

max_hops: u16

Maximum hops before packet is dropped (prevents loops)

payload: Vec<u8>

Payload data (opaque to router)

Implementations

impl DataPacket

pub fn telemetry(source_node_id: impl Into<String>, payload: Vec<u8>) -> Self

Create a new telemetry packet

pub fn command( source_node_id: impl Into<String>, destination_node_id: impl Into<String>, payload: Vec<u8>, ) -> Self

Create a new command packet

pub fn status(source_node_id: impl Into<String>, payload: Vec<u8>) -> Self

Create a new status update packet

pub fn coordination( source_node_id: impl Into<String>, destination_node_id: impl Into<String>, payload: Vec<u8>, ) -> Self

Create a new coordination packet (lateral)

pub fn aggregated_telemetry( source_node_id: impl Into<String>, payload: Vec<u8>, ) -> Self

Create an aggregated telemetry packet

pub fn increment_hop(&mut self) -> bool

Increment hop count when forwarding packet

Returns true if packet can be forwarded (not yet at max hops), false if packet should be dropped.

pub fn at_max_hops(&self) -> bool

Check if packet has reached maximum hop count

Trait Implementations

impl Clone for DataPacket

fn clone(&self) -> DataPacket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataPacket

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DataPacket

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DataPacket

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.