Enum ResponseItem 

pub enum ResponseItem {
    AgentCompletionRequest {
        id: i64,
        agent_instance_hierarchy: String,
        sender_agent_instance_hierarchy: String,
        delivered_at: String,
        response_id: String,
    },
    VectorCompletionRequest {
        id: i64,
        agent_instance_hierarchy: String,
        sender_agent_instance_hierarchy: String,
        delivered_at: String,
        response_id: String,
    },
    FunctionExecutionRequest {
        id: i64,
        agent_instance_hierarchy: String,
        sender_agent_instance_hierarchy: String,
        delivered_at: String,
        response_id: String,
    },
    ClientNotification {
        agent_instance_hierarchy: String,
        sender_agent_instance_hierarchy: String,
        response_id: String,
        queued_at: String,
        key: Option<String>,
        parts: Vec<ClientNotificationPart>,
    },
    AssistantResponse {
        agent_instance_hierarchy: String,
        response_id: String,
        parts: Vec<AssistantResponsePart>,
    },
    ToolResponse {
        agent_instance_hierarchy: String,
        response_id: String,
        tool_call_id: String,
        parts: Vec<ToolResponsePart>,
    },
}

One yielded item. Three single-row request blobs + three multi-row blocks. Every variant carries response_id. sender_agent_instance_hierarchy appears only on the four variants that have a sender ≠ producer: the three request variants (caller AIH) and ClientNotification (enqueuer AIH). AssistantResponse and ToolResponse are emitted BY the agent itself — their agent_instance_hierarchy IS the producer, so no separate sender field exists.

Block-coalescing boundary tuple: (class, agent_instance_hierarchy, response_id) for AssistantResponse; (class, agent_instance_hierarchy, response_id, tool_call_id) for ToolResponse (one block per tool call); (class, agent_instance_hierarchy, response_id, sender, message_queue_id) for ClientNotification blocks. One ClientNotification block = one consumed message_queue parent row, so queued_at and sender_agent_instance_hierarchy are well-defined block-level.

Variants

AgentCompletionRequest

Fields

id: i64

agent_instance_hierarchy: String

sender_agent_instance_hierarchy: String

AIH of the caller who issued the request — from logs.agent_completion_requests.sender_*.

delivered_at: String

response_id: String

VectorCompletionRequest

Fields

id: i64

agent_instance_hierarchy: String

sender_agent_instance_hierarchy: String

delivered_at: String

response_id: String

FunctionExecutionRequest

Fields

id: i64

agent_instance_hierarchy: String

sender_agent_instance_hierarchy: String

delivered_at: String

response_id: String

ClientNotification

Fields

agent_instance_hierarchy: String

sender_agent_instance_hierarchy: String

AIH of the enqueuer — from message_queue.sender_* joined through message_queue_contents.id.

response_id: String

queued_at: String

message_queue.enqueued_at of the consumed parent queue row. One block = one parent queue row, so this is well-defined block-level (each part’s individual delivered_at still records its own consumption moment).

key: Option<String>

Idempotency token, if the row was enqueued with --key via agents message --enqueue-with-key. Surfacing it lets readers attribute a notification to a specific enqueue beyond just the sender AIH.

parts: Vec<ClientNotificationPart>

AssistantResponse

Agent emissions — the agent IS the producer of these rows, so there’s no separate sender. The agent_instance_hierarchy field IS the sender.

Fields

agent_instance_hierarchy: String

response_id: String

parts: Vec<AssistantResponsePart>

ToolResponse

One tool call’s response. Blocks are grouped per tool_call_id (in addition to agent_instance_hierarchy + response_id), so two responses in the same turn yield two blocks.

Fields

agent_instance_hierarchy: String

response_id: String

tool_call_id: String

The wire tool-call id this response answers.

parts: Vec<ToolResponsePart>

Trait Implementations

impl Clone for ResponseItem

fn clone(&self) -> ResponseItem

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CommandResponse for ResponseItem

Available on crate feature mcp only.

fn into_mcp(self) -> McpResponseItem

impl Debug for ResponseItem

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ResponseItem

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ResponseItem

impl JsonSchema for ResponseItem

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for ResponseItem

fn eq(&self, other: &ResponseItem) -> 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 ResponseItem

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 ResponseItem