Struct Message 

pub struct Message {
    pub id: String,
    pub from: AgentId,
    pub to: AgentId,
    pub content: Content,
    pub timestamp: DateTime<Utc>,
    pub metadata: HashMap<String, Value>,
    pub priority: u8,
}

Message between agents

Fields

id: String

Unique message ID

from: AgentId

Sender agent ID

to: AgentId

Recipient agent ID

content: Content

Message content

timestamp: DateTime<Utc>

Message timestamp

metadata: HashMap<String, Value>

Message metadata

priority: u8

Message priority (0-255, higher = more urgent)

Implementations

impl Message

pub fn new(from: AgentId, to: AgentId, content: Content) -> Self

Create a new message

pub fn system(to: AgentId, content: Content) -> Self

Create a system message (from system to agent)

pub fn system_welcome(to: &AgentId) -> Self

Create a system welcome message

pub fn user(to: AgentId, text: impl Into<String>) -> Self

Create a user message

pub fn with_priority(self, priority: u8) -> Self

Set message priority

pub fn with_metadata(self, key: impl Into<String>, value: Value) -> Self

Add metadata

pub fn is_tool_call(&self) -> bool

Check if message is a tool call

pub fn is_tool_result(&self) -> bool

Check if message is a tool result

pub fn is_text(&self) -> bool

Check if message is plain text

pub fn as_text(&self) -> Option<&str>

Get text content if available

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.