Enum GlobalMessage 

pub enum GlobalMessage {
    Direct {
        sender: String,
        recipient: String,
        content: MessageContent,
    },
    Broadcast {
        sender: String,
        topic: String,
        content: MessageContent,
    },
    Request {
        sender: String,
        recipient: String,
        request_id: String,
        content: MessageContent,
        expect_reply: bool,
    },
    Response {
        responder: String,
        request_id: String,
        content: MessageContent,
    },
    PubSub {
        publisher: String,
        topic: String,
        content: MessageContent,
    },
}

全局消息类型

替代多处重复的 AgentMessage 定义，提供全局消息抽象。

消息模式

• Direct: 点对点直接消息
• Broadcast: 广播消息到所有订阅者
• Request: 请求消息（期待响应）
• Response: 响应消息
• PubSub: 发布-订阅模式

Variants

Direct

点对点直接消息

Fields

sender: String

发送者 ID

recipient: String

接收者 ID

content: MessageContent

消息内容

Broadcast

广播消息

Fields

sender: String

发送者 ID

topic: String

主题

content: MessageContent

消息内容

Request

请求消息（期待响应）

Fields

sender: String

发送者 ID

recipient: String

接收者 ID

request_id: String

请求 ID（用于匹配响应）

content: MessageContent

消息内容

expect_reply: bool

是否期待响应

Response

响应消息

Fields

responder: String

响应者 ID

request_id: String

请求 ID（用于匹配原始请求）

content: MessageContent

消息内容

PubSub

发布-订阅消息

Fields

publisher: String

发布者 ID

topic: String

主题

content: MessageContent

消息内容

Implementations

impl GlobalMessage

pub fn sender(&self) -> &str

获取消息发送者 ID

pub fn message_type(&self) -> &'static str

获取消息类型标识

pub fn direct( sender: impl Into<String>, recipient: impl Into<String>, content: MessageContent, ) -> GlobalMessage

创建点对点消息

pub fn broadcast( sender: impl Into<String>, topic: impl Into<String>, content: MessageContent, ) -> GlobalMessage

创建广播消息

pub fn request( sender: impl Into<String>, recipient: impl Into<String>, request_id: impl Into<String>, content: MessageContent, ) -> GlobalMessage

创建请求消息

pub fn response( responder: impl Into<String>, request_id: impl Into<String>, content: MessageContent, ) -> GlobalMessage

创建响应消息

Trait Implementations

impl Clone for GlobalMessage

fn clone(&self) -> GlobalMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GlobalMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GlobalMessage

fn deserialize<__D>( __deserializer: __D, ) -> Result<GlobalMessage, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for GlobalMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.