dwctl 8.40.0

The Doubleword Control Layer - A self-hostable observability and analytics platform for LLM applications
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use utoipa::{IntoParams, ToSchema};
use uuid::Uuid;

use super::pagination::Pagination;

/// Query parameters for listing batch requests
#[derive(Debug, Default, Deserialize, IntoParams, ToSchema)]
pub struct ListBatchRequestsQuery {
    #[serde(flatten)]
    #[param(inline)]
    pub pagination: Pagination,

    /// Filter by batch completion window (e.g., "1h", "24h")
    pub completion_window: Option<String>,

    /// Filter by request state (pending, processing, completed, failed, canceled)
    pub status: Option<String>,

    /// Filter by model
    pub model: Option<String>,

    /// Filter by batch creator (user ID or org ID)
    pub member_id: Option<uuid::Uuid>,

    /// Filter to requests created after this timestamp
    pub created_after: Option<DateTime<Utc>>,

    /// Filter to requests created before this timestamp
    pub created_before: Option<DateTime<Utc>>,

    /// Sort active requests first (default: true)
    pub active_first: Option<bool>,
}

/// Individual batch request summary for list endpoint.
/// Combines fusillade request data with http_analytics enrichment.
#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
pub struct BatchRequestSummary {
    pub id: Uuid,
    pub batch_id: Uuid,
    pub model: String,
    pub status: String,
    pub created_at: DateTime<Utc>,
    pub completed_at: Option<DateTime<Utc>>,
    pub failed_at: Option<DateTime<Utc>>,
    pub duration_ms: Option<f64>,
    pub response_status: Option<i16>,
    pub prompt_tokens: Option<i64>,
    pub completion_tokens: Option<i64>,
    pub reasoning_tokens: Option<i64>,
    pub total_tokens: Option<i64>,
    pub total_cost: Option<f64>,
    pub created_by_email: Option<String>,
}

/// Full batch request detail including input/output.
/// Combines fusillade request detail with http_analytics enrichment.
#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
pub struct BatchRequestDetail {
    pub id: Uuid,
    pub batch_id: Uuid,
    pub model: String,
    pub status: String,
    pub created_at: DateTime<Utc>,
    pub completed_at: Option<DateTime<Utc>>,
    pub failed_at: Option<DateTime<Utc>>,
    pub duration_ms: Option<f64>,
    pub response_status: Option<i16>,
    pub prompt_tokens: Option<i64>,
    pub completion_tokens: Option<i64>,
    pub reasoning_tokens: Option<i64>,
    pub total_tokens: Option<i64>,
    pub total_cost: Option<f64>,
    pub body: String,
    pub response_body: Option<String>,
    pub error: Option<String>,
    pub completion_window: String,
    pub batch_created_by: String,
    pub created_by_email: Option<String>,
}