Struct OutboundMessage 

pub struct OutboundMessage {
    pub channel: String,
    pub to: Recipient,
    pub body: String,
    pub idempotency_key: Option<String>,
}

One outbound message, as the runtime hands it to a sink.

Fields

channel: String

Channel name — “imessage”, or any name a host adapter answers to. The runtime keeps no list of valid channels; the sink is the authority.

to: Recipient

Who the message is for.

body: String

The message text, as the human will read it.

idempotency_key: Option<String>

Caller-supplied dedup key. A retry after a delivered-but-timed-out send is the classic duplicate-message bug — the transport succeeded, the acknowledgement did not arrive, the caller retries, and the human gets the same message twice. A sink that honours this key makes the retry safe. None means “no dedup”, which is the right answer for a message the caller genuinely wants sent again.

Implementations

impl OutboundMessage

pub fn from_tool_params(params: &Value) -> Result<Self, String>

Parse the messaging.send tool parameters into a message.

Errors are written for two readers at once: the model, which has to fix the call on its next turn, and the operator reading the event log. Both need to know which field was wrong and what a correct one looks like, so every message names the offending key and the accepted shape.

There is deliberately exactly one accepted spelling of the address parameter: to, the name the schema advertises. Policy rules match the LITERAL parameter key, so an alias would be an ungoverned spelling of a governed field — a rule written as allow_tool_param { param = "to" } would simply not see a call that spelled it differently.

Trait Implementations

impl Clone for OutboundMessage

fn clone(&self) -> OutboundMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboundMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OutboundMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for OutboundMessage

impl PartialEq for OutboundMessage

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for OutboundMessage

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 OutboundMessage