Enum BrokerMessage 

pub enum BrokerMessage {
    Status {
        agent_id: String,
        payload: StatusPayload,
    },
    Artifact {
        agent_id: String,
        payload: ArtifactPayload,
    },
    Blocked {
        agent_id: String,
        payload: BlockedPayload,
    },
    Verified {
        agent_id: String,
        payload: VerifiedPayload,
    },
    Feedback {
        agent_id: String,
        payload: FeedbackPayload,
    },
    Question {
        agent_id: String,
        payload: QuestionPayload,
    },
    Intent {
        agent_id: String,
        payload: IntentPayload,
    },
    AdvancedMain {
        payload: AdvancedMainPayload,
    },
    Learning {
        payload: LearningPayload,
    },
    VerifyNow {
        branch_id: String,
    },
}

Envelope for all inter-agent messages.

The wire format uses JSON with an internally tagged "type" discriminator whose values are "agent.status", "agent.artifact", "agent.blocked", "agent.verified", "agent.feedback", "agent.question", "agent.intent", "agent.advanced-main", "agent.learning", and "supervisor.verify-now". The last is broker-emitted rather than agent-published; see BrokerMessage::VerifyNow.

Eq is intentionally not derived: the agent.learning payload carries a serde_json::Value body, which is PartialEq but not Eq.

Variants

Status

Status heartbeat – not routed to inboxes.

Fields

agent_id: String

Sender agent ID (slugified branch name).

payload: StatusPayload

Status payload.

Artifact

Artifact announcement – broadcast to all peers.

Fields

agent_id: String

Sender agent ID.

payload: ArtifactPayload

Artifact payload.

Blocked

Blocked notification – sent to the target agent.

Fields

agent_id: String

Sender agent ID.

payload: BlockedPayload

Blocked payload (contains from – the unblocking agent).

Verified

Verification acknowledgement – broadcast to all peers.

Fields

agent_id: String

Target agent ID (the agent whose work was verified).

payload: VerifiedPayload

Verified payload (contains verified_by – the sender).

Feedback

Feedback from a verifier – delivered to the target agent only.

Fields

agent_id: String

Target agent ID (the agent receiving feedback).

payload: FeedbackPayload

Feedback payload (contains from – the sender).

Question

Agent question – delivered to the "supervisor" inbox for human reply.

Fields

agent_id: String

Sender agent ID (the agent asking the question).

payload: QuestionPayload

Question payload.

Intent

Intent announcement – broadcast to every other registered agent’s inbox.

Lets peers (and the broker conflict detector) see which files an agent is about to modify before any commit lands.

Fields

agent_id: String

Sender agent ID (the agent declaring the intent).

payload: IntentPayload

Intent payload.

AdvancedMain

Main-advanced notification – published by the supervisor after a successful merge to the default branch, broadcast to every registered agent’s inbox so dependents learn the base moved.

The payload is flattened into the envelope (its fields sit at the top level alongside "type", not nested under a payload key) so the wire shape matches the curl example the supervisor skill teaches. The sender identity is the payload’s from field (typically "supervisor"), surfaced through BrokerMessage::agent_id.

Fields

payload: AdvancedMainPayload

Flattened advanced-main payload (from, merged_branch, new_main_sha, base, merged_at, optional summary).

Learning

Structured learning record – published by the broker’s learnings aggregator when [supervisor] learnings = true and broker publish is active (see crate::broker::learnings). Carries a deterministic dedup id so consumers can collapse re-emissions. Routed to the scoped branch_id inbox when present, otherwise the supervisor inbox; always retained in the broker message log. The variant is additive – existing consumers ignore unknown types per the broker-messages contract.

Fields

payload: LearningPayload

Learning payload (carries its own agent_id).

VerifyNow

Supervisor verification nudge – emitted by the broker (not by an agent) when an agent.artifact { status: "committed" } arrives and [supervisor].verify_on_commit_nudge is enabled. Delivered to the "supervisor" inbox so per-commit verification is triggered by an explicit event rather than relying on the supervisor’s sweep cadence to notice the commit.

Unlike the agent.* variants this carries a branch_id directly (the committing branch) rather than a sender agent_id plus a payload – the message originates from the broker itself, so there is no publishing agent.

Fields

branch_id: String

The committing branch whose commit should be verified now. Copied verbatim from the triggering artifact’s agent_id.

Implementations

impl BrokerMessage

pub fn from_json(input: &str) -> Result<Self, MessageError>

Deserializes and validates a broker message from a JSON string.

Returns MessageError if the JSON is malformed or the agent_id is invalid.

pub fn agent_id(&self) -> &str

Returns the agent_id field from whichever variant.

pub fn status_label(&self) -> &str

Returns a short status label for the message.

• Status returns payload.status (e.g. "working")
• Artifact returns payload.status (e.g. "done")
• Blocked returns "blocked"
• Verified returns "verified"
• Feedback returns "feedback"
• Question returns "question"
• Intent returns "intent"
• AdvancedMain returns "advanced-main"
• VerifyNow returns "verify-now"

Trait Implementations

impl Clone for BrokerMessage

fn clone(&self) -> BrokerMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BrokerMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BrokerMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for BrokerMessage

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

Formats the value using the given formatter.

impl From<&LearningRecord> for BrokerMessage

fn from(record: &LearningRecord) -> Self

Converts to this type from the input type.

impl PartialEq for BrokerMessage

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for BrokerMessage

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 BrokerMessage