Enum PeerMessage 

pub enum PeerMessage {
    Hello {
        from: PeerId,
        capabilities: Vec<PeerCapability>,
    },
    Broadcast {
        from: PeerId,
        topic: String,
        payload: Value,
    },
    Direct {
        from: PeerId,
        to: PeerId,
        payload: Value,
    },
    Task {
        from: PeerId,
        task_id: String,
        spec: Value,
        issued_at: DateTime<Utc>,
    },
    Result {
        from: PeerId,
        task_id: String,
        result: Value,
        ok: bool,
    },
}

One message on the mesh.

Variants

Hello

First message after a connection establishes — peers identify themselves and advertise capabilities.

Fields

from: PeerId

Sender id.

capabilities: Vec<PeerCapability>

Capability set.

Broadcast

Fanout publish to every peer subscribed to topic.

Fields

from: PeerId

Sender id.

topic: String

Free-form topic.

payload: Value

Arbitrary JSON payload.

Direct

Point-to-point delivery.

Fields

from: PeerId

Sender.

to: PeerId

Intended recipient.

payload: Value

Arbitrary JSON payload.

Task

Distributed task assignment.

Fields

from: PeerId

Sender (originator).

task_id: String

Task id (caller-chosen or auto).

spec: Value

Task description.

issued_at: DateTime<Utc>

Wall-clock time the task was published.

Result

Result of a previously-issued PeerMessage::Task.

Fields

from: PeerId

Responder.

task_id: String

Same task_id as the originating Task.

result: Value

Result payload.

ok: bool

Whether the task completed successfully.

Implementations

impl PeerMessage

pub fn sender(&self) -> &PeerId

Sender id, useful for routing decisions.

pub fn broadcast( from: impl Into<PeerId>, topic: impl Into<String>, payload: Value, ) -> Self

Convenience: build a broadcast message.

pub fn direct( from: impl Into<PeerId>, to: impl Into<PeerId>, payload: Value, ) -> Self

Convenience: build a direct message.

pub fn task(from: impl Into<PeerId>, spec: Value) -> Self

Convenience: build a task with an auto-generated id.

Trait Implementations

impl Clone for PeerMessage

fn clone(&self) -> PeerMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PeerMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PeerMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PeerMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.