Enum ClientMessage 

pub enum ClientMessage {
    Send {
        agent: CompactString,
        content: String,
        session: Option<u64>,
        sender: Option<CompactString>,
    },
    Stream {
        agent: CompactString,
        content: String,
        session: Option<u64>,
        sender: Option<CompactString>,
    },
    Download {
        model: CompactString,
    },
    Ping,
    Hub {
        package: CompactString,
        action: HubAction,
    },
    Sessions,
    Kill {
        session: u64,
    },
    Tasks,
    KillTask {
        task_id: u64,
    },
    Approve {
        task_id: u64,
        response: String,
    },
    Evaluate {
        agent: CompactString,
        content: String,
        session: Option<u64>,
        sender: Option<CompactString>,
    },
    SubscribeTasks,
    Downloads,
    SubscribeDownloads,
    GetConfig,
    SetConfig {
        config: String,
    },
    MemoryQuery {
        query: MemoryOp,
    },
}

Messages sent by the client to the gateway.

Variants

Send

Send a message to an agent and receive a complete response.

Fields

agent: CompactString

Target agent identifier.

content: String

Message content.

session: Option<u64>

Session to reuse. None creates a new session.

sender: Option<CompactString>

Sender identity. None = local.

Stream

Send a message to an agent and receive a streamed response.

Fields

agent: CompactString

Target agent identifier.

content: String

Message content.

session: Option<u64>

Session to reuse. None creates a new session.

sender: Option<CompactString>

Sender identity. None = local.

Download

Request download of a model’s files with progress reporting.

Fields

model: CompactString

HuggingFace model ID (e.g. “microsoft/Phi-3.5-mini-instruct”).

Ping

Ping the server (keepalive).

Hub

Install or uninstall a hub package.

Fields

package: CompactString

Package identifier in scope/name format.

action: HubAction

Action to perform.

Sessions

List active sessions.

Kill

Kill (close) a session.

Fields

session: u64

Session ID to close.

Tasks

List tasks in the task registry.

KillTask

Kill (cancel) a task.

Fields

task_id: u64

Task ID to cancel.

Approve

Approve a blocked task’s inbox item.

Fields

task_id: u64

Task ID to approve.

response: String

Response to send to the blocked tool call.

Evaluate

Evaluate whether the agent should respond to a message.

Used by channel loops for group-chat gating (DD#39). Returns ServerMessage::Evaluation with a boolean decision.

Fields

agent: CompactString

Target agent identifier.

content: String

Message content to evaluate.

session: Option<u64>

Session to use for context. None creates a temporary session.

sender: Option<CompactString>

Sender identity. None = local.

SubscribeTasks

Subscribe to task lifecycle events (streaming).

Downloads

List downloads in the download registry.

SubscribeDownloads

Subscribe to download lifecycle events (streaming).

GetConfig

Get the full daemon config as JSON.

SetConfig

Replace the full daemon config from JSON.

Fields

config: String

JSON-serialized DaemonConfig.

MemoryQuery

Query the memory graph.

Fields

query: MemoryOp

The query operation to perform.

Trait Implementations

impl Clone for ClientMessage

fn clone(&self) -> ClientMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClientMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClientMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<DownloadRequest> for ClientMessage

fn from(r: DownloadRequest) -> Self

Converts to this type from the input type.

impl From<HubRequest> for ClientMessage

fn from(r: HubRequest) -> Self

Converts to this type from the input type.

impl From<SendRequest> for ClientMessage

fn from(r: SendRequest) -> Self

Converts to this type from the input type.

impl From<StreamRequest> for ClientMessage

fn from(r: StreamRequest) -> Self

Converts to this type from the input type.

impl Serialize for ClientMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.