acp_cli/queue/
messages.rs

1use serde::{Deserialize, Serialize};
2
3/// Message from client to queue owner.
4#[derive(Debug, Serialize, Deserialize, PartialEq)]
5#[serde(tag = "type", rename_all = "snake_case")]
6pub enum QueueRequest {
7    Prompt {
8        messages: Vec<String>,
9        reply_id: String,
10    },
11    Cancel,
12    Status,
13    SetMode {
14        mode: String,
15    },
16    SetConfig {
17        key: String,
18        value: String,
19    },
20}
21
22/// Message from queue owner to client.
23#[derive(Debug, Serialize, Deserialize, PartialEq)]
24#[serde(tag = "type", rename_all = "snake_case")]
25pub enum QueueResponse {
26    PromptResult {
27        reply_id: String,
28        content: String,
29        stop_reason: String,
30    },
31    Event {
32        kind: String,
33        data: String,
34    },
35    StatusResponse {
36        state: String,
37        queue_depth: usize,
38    },
39    Error {
40        message: String,
41    },
42    Queued {
43        reply_id: String,
44        position: usize,
45    },
46    Ok,
47}
acp_cli/queue/messages.rs

acp_cli/queue/
messages.rs
