Enum P2PEvent 

pub enum P2PEvent {
    Message {
        topic: String,
        source: Option<PeerId>,
        transport_source: Option<MultiAddr>,
        timestamp: u64,
        data: Vec<u8>,
    },
    PeerConnected(PeerId, String),
    PeerDisconnected(PeerId),
}

Network events that can occur in the P2P system

Events are broadcast to all listeners and provide real-time notifications of network state changes and message arrivals.

Variants

Message

Message received from a peer on a specific topic

Fields

topic: String

Topic or channel the message was sent on

source: Option<PeerId>

For signed messages this is the authenticated app-level PeerId; None for unsigned messages.

transport_source: Option<MultiAddr>

IP transport address that delivered this message, when known.

This is provenance metadata, not an identity signal.

timestamp: u64

Sender-supplied Unix timestamp in seconds.

For signed messages this value is covered by the ML-DSA-65 signature alongside the payload, so handlers can use it for application-level freshness or replay defense. Wire-level acceptance no longer gates on this value; subscribers MUST do their own age/dedup checks when the protocol requires them.

data: Vec<u8>

Raw message data payload

PeerConnected(PeerId, String)

An authenticated peer has connected (first signed message verified on any channel). The user_agent identifies the remote software (e.g. "node/0.12.1", "client/1.0").

PeerDisconnected(PeerId)

An authenticated peer has fully disconnected (all channels closed).

Trait Implementations

impl Clone for P2PEvent

fn clone(&self) -> P2PEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for P2PEvent

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

Formats the value using the given formatter.