Struct BusMessage 

pub struct BusMessage {
    pub id: String,
    pub content: Value,
    pub source: String,
    pub target: Option<String>,
    pub template: Option<String>,
    pub timestamp: DateTime<Utc>,
    pub metadata: Metadata,
}

Inter-agent or user steering message.

Fields

id: String

Stable message id used for idempotent send and consume.

content: Value

Renderable text or JSON content.

source: String

Sender identifier such as user, main, or a subagent id.

target: Option<String>

Recipient agent id. None means broadcast to all subscribers.

template: Option<String>

Optional template string. The Rust context stores the value; rendering is caller-owned.

timestamp: DateTime<Utc>

Message creation time.

metadata: Metadata

Additional message metadata.

Implementations

impl BusMessage

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

Create a topic-scoped message.

pub fn text(content: impl Into<String>, source: impl Into<String>) -> Self

Create a text bus message.

pub fn with_id(self, id: impl Into<String>) -> Self

Set an explicit message id.

pub fn with_target(self, target: impl Into<String>) -> Self

Set target recipient.

pub fn with_source(self, source: impl Into<String>) -> Self

Set source sender.

pub fn with_template(self, template: impl Into<String>) -> Self

Set template metadata.

pub fn content_text(&self) -> String

Return message text for logs, steering, and display.

pub fn render_text(&self) -> String

Render message content. Minimal template support keeps raw content unless no JSON text exists.

Trait Implementations

impl Clone for BusMessage

fn clone(&self) -> BusMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BusMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BusMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BusMessage

impl PartialEq for BusMessage

fn eq(&self, other: &BusMessage) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for BusMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for BusMessage