Struct TeamMessage 

pub struct TeamMessage {

    pub id: String,
    pub run_id: String,
    pub task_id: Option<String>,
    pub kind: TeamMessageKind,
    pub sender_agent_id: Option<String>,
    pub recipient_agent_id: Option<String>,
    pub content: String,
    pub thread_id: Option<String>,
    pub reply_to_message_id: Option<String>,
    pub action_request: Option<TeamActionRequest>,
    pub escalation: Option<TeamEscalation>,
    pub result_reference: Option<TeamResultReference>,
    pub artifact_references: Vec<TeamArtifactReference>,
    pub unread_by_agent_ids: Vec<String>,
    pub archived_at: Option<DateTime<Utc>>,
    pub archived_by_agent_id: Option<String>,
    pub archive_note: Option<String>,
    pub created_at: DateTime<Utc>,
}

Message exchanged within a supervisor run.

Fields

id: String

Message identifier.

run_id: String

Run identifier.

task_id: Option<String>

Optional task identifier this message refers to.

kind: TeamMessageKind

Message kind.

sender_agent_id: Option<String>

Sender agent identifier.

recipient_agent_id: Option<String>

Recipient agent identifier.

content: String

Human-readable content.

thread_id: Option<String>

Stable thread identifier.

reply_to_message_id: Option<String>

Parent message identifier for replies.

action_request: Option<TeamActionRequest>

Actionable request metadata.

escalation: Option<TeamEscalation>

Escalation metadata.

result_reference: Option<TeamResultReference>

Optional result reference.

artifact_references: Vec<TeamArtifactReference>

Linked artifacts.

unread_by_agent_ids: Vec<String>

Agents that have not yet read the message.

archived_at: Option<DateTime<Utc>>

When this message/thread was archived.

archived_by_agent_id: Option<String>

Who archived this message/thread.

archive_note: Option<String>

Optional archive note.

created_at: DateTime<Utc>

Creation timestamp.

Implementations

impl TeamMessage

pub fn new( run_id: impl Into<String>, task_id: Option<String>, kind: TeamMessageKind, sender_agent_id: Option<String>, recipient_agent_id: Option<String>, content: impl Into<String>, ) -> Self

Build a new team message.

pub fn with_thread( self, thread_id: String, reply_to_message_id: Option<String>, ) -> Self

Attach thread metadata.

pub fn with_action_request(self, action_request: TeamActionRequest) -> Self

Attach an action request to the message.

pub fn with_result_reference( self, result_reference: TeamResultReference, ) -> Self

Attach a result reference to the message.

pub fn with_artifact_references( self, artifact_references: Vec<TeamArtifactReference>, ) -> Self

Attach artifact references to the message.

pub fn with_escalation(self, escalation: TeamEscalation) -> Self

Attach escalation metadata to the message.

pub fn with_unread_by_agent_ids(self, unread_by_agent_ids: Vec<String>) -> Self

Attach unread markers to the message.

pub fn archive( &mut self, archived_by_agent_id: Option<String>, archive_note: Option<String>, )

Mark the message as archived.

pub fn is_archived(&self) -> bool

Whether this message is archived.

pub fn effective_thread_id(&self) -> &str

Return the stable thread id for grouping.

Trait Implementations

impl Clone for TeamMessage

fn clone(&self) -> TeamMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TeamMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TeamMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TeamMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.