Struct A2AMessage 

pub struct A2AMessage {
    pub id: String,
    pub from_agent: String,
    pub to_agent: Option<String>,
    pub task_id: Option<String>,
    pub category: MessageCategory,
    pub priority: MessagePriority,
    pub privacy: PrivacyLevel,
    pub content: String,
    pub metadata: HashMap<String, String>,
    pub timestamp: DateTime<Utc>,
    pub read_by: Vec<String>,
    pub expires_at: Option<DateTime<Utc>>,
}

Fields

id: String

from_agent: String

to_agent: Option<String>

task_id: Option<String>

category: MessageCategory

priority: MessagePriority

privacy: PrivacyLevel

content: String

metadata: HashMap<String, String>

timestamp: DateTime<Utc>

read_by: Vec<String>

expires_at: Option<DateTime<Utc>>

Implementations

impl A2AMessage

pub fn new( from: &str, to: Option<&str>, category: MessageCategory, content: &str, ) -> Self

pub fn with_task(self, task_id: &str) -> Self

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

pub fn with_privacy(self, privacy: PrivacyLevel) -> Self

pub fn with_ttl_hours(self, hours: u64) -> Self

pub fn is_expired(&self) -> bool

pub fn is_visible_to(&self, agent_id: &str) -> bool

pub fn mark_read(&mut self, agent_id: &str)

Trait Implementations

impl Clone for A2AMessage

fn clone(&self) -> A2AMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for A2AMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for A2AMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for A2AMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.