Enum Payload 

pub enum Payload {
    Initialize {
        mcp_kind: McpKind,
        params: InitializeRequest,
    },
    ToolsList {
        mcp_kind: McpKind,
        params: ListToolsRequest,
    },
    ToolsCall {
        mcp_kind: McpKind,
        params: CallToolRequestParams,
    },
    ResourcesList {
        mcp_kind: McpKind,
        params: ListResourcesRequest,
    },
    ResourcesRead {
        mcp_kind: McpKind,
        params: ReadResourceRequestParams,
    },
    SessionTerminate {
        mcp_kind: McpKind,
    },
    ReadMessageQueue(ReadMessageQueueRequest),
    Retrieve(Request),
}

Tagged union of every JSON-RPC request the API forwards to the client over the reverse-attach WS. Variant names follow the same snake_case convention client_request::Payload uses; the serde(tag = "type") discriminator pairs with super::super::server_response::Payload by name.

MCP-routed variants carry mcp_kind directly on the variant (alongside the typed params via #[serde(flatten)]). The non-MCP ReadMessageQueue variant doesn’t carry mcp_kind at all — it hits the CLI’s own local state and never routes to an upstream MCP server. Use Payload::mcp_kind to retrieve it generically.

Variants

Initialize

POST initialize. The proxy’s protocolVersion doesn’t ride across this hop — the API discards it on the way in and substitutes its own canonical_initialize_result on the way out. The variant carries the plugin arguments the CLI needs at dial time (parsed by the API off the URL query string).

Fields

mcp_kind: McpKind

params: InitializeRequest

ToolsList

POST tools/list.

Fields

mcp_kind: McpKind

params: ListToolsRequest

ToolsCall

POST tools/call.

Fields

mcp_kind: McpKind

params: CallToolRequestParams

ResourcesList

POST resources/list.

Fields

mcp_kind: McpKind

params: ListResourcesRequest

ResourcesRead

POST resources/read.

Fields

mcp_kind: McpKind

params: ReadResourceRequestParams

SessionTerminate

DELETE on the routed MCP URL — the proxy closing the session. No body beyond mcp_kind.

Fields

mcp_kind: McpKind

ReadMessageQueue(ReadMessageQueueRequest)

Read the CLI’s local message queue for a given agent hierarchy. Non-MCP — no mcp_kind. Non-destructive: the API stamps the consumed ids onto the first AssistantResponseChunk.request_message_ids it emits so the downstream consumer owns row deletion; no separate release RPC.

Retrieve(Request)

Resolve a Client remote from the client’s own local storage (agent / swarm / function / profile). Non-MCP — no mcp_kind.

Implementations

impl Payload

pub fn mcp_kind(&self) -> Option<McpKind>

Which CLI-hosted MCP server this payload targets. Some for the MCP-routed variants; None for ReadMessageQueue which hits the CLI’s own local state.

Trait Implementations

impl Clone for Payload

fn clone(&self) -> Payload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Payload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Payload

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for Payload

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 Serialize for Payload

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

where __S: Serializer,

Serialize this value into the given Serde serializer.