342 lines
13 KiB
Go
342 lines
13 KiB
Go
package v1
|
||
|
||
import (
|
||
"encoding/json"
|
||
|
||
"github.com/gogf/gf/v2/frame/g"
|
||
)
|
||
|
||
// === 监控仪表盘 ===
|
||
|
||
type MonitorDashboardReq struct {
|
||
g.Meta `path:"/monitor/dashboard" method:"get" mime:"json" tags:"管理后台-监控" summary:"监控仪表盘"`
|
||
Minutes int `json:"minutes" in:"query" d:"5"`
|
||
}
|
||
|
||
// MonitorDashboardRes 数据对象平铺进统一响应的 data 字段（json:"-" + 自定义 MarshalJSON），
|
||
// 避免统一包装后再多包一层 data（monitor 包下带 Data 的 Res 均为此模式）
|
||
type MonitorDashboardRes struct {
|
||
Data map[string]any `json:"-"`
|
||
}
|
||
|
||
func (r *MonitorDashboardRes) MarshalJSON() ([]byte, error) {
|
||
return json.Marshal(r.Data)
|
||
}
|
||
|
||
type MonitorTrafficReq struct {
|
||
g.Meta `path:"/monitor/traffic" method:"get" mime:"json" tags:"管理后台-监控" summary:"流量曲线"`
|
||
Minutes int `json:"minutes" in:"query" d:"30"`
|
||
}
|
||
|
||
type MonitorTrafficRes struct {
|
||
Data any `json:"-"`
|
||
}
|
||
|
||
func (r *MonitorTrafficRes) MarshalJSON() ([]byte, error) {
|
||
return json.Marshal(r.Data)
|
||
}
|
||
|
||
type MonitorTrafficFlowReq struct {
|
||
g.Meta `path:"/monitor/traffic-flow" method:"get" mime:"json" tags:"管理后台-监控" summary:"流量流向桑基图"`
|
||
StartDate string `json:"start_date" in:"query"` // YYYY-MM-DD，缺省=近30天起点
|
||
EndDate string `json:"end_date" in:"query"` // YYYY-MM-DD，缺省=今天
|
||
Metric string `json:"metric" in:"query" d:"cost"` // cost|tokens|requests，桑基边权重指标
|
||
}
|
||
|
||
type MonitorTrafficFlowRes struct {
|
||
Data any `json:"-"`
|
||
}
|
||
|
||
func (r *MonitorTrafficFlowRes) MarshalJSON() ([]byte, error) {
|
||
return json.Marshal(r.Data)
|
||
}
|
||
|
||
type MonitorModelPerformanceReq struct {
|
||
g.Meta `path:"/monitor/model-performance" method:"get" mime:"json" tags:"管理后台-监控" summary:"模型性能指标"`
|
||
StartDate string `json:"start_date" in:"query"` // YYYY-MM-DD，缺省=近30天起点
|
||
EndDate string `json:"end_date" in:"query"` // YYYY-MM-DD，缺省=今天
|
||
// 可选渠道筛选：0=全部渠道（选定渠道后当天数据改从 bil_usage_logs 明细实时聚合；0 哨兵被占用，无法筛「无渠道」）
|
||
ChannelId int64 `json:"channel_id" in:"query" d:"0"`
|
||
// 可选模型筛选：空=全部模型（与 bil_usage_daily.model_name 同口径）
|
||
ModelName string `json:"model_name" in:"query"`
|
||
}
|
||
|
||
type MonitorModelPerformanceRes struct {
|
||
List []ModelPerformanceSummary `json:"list"`
|
||
}
|
||
|
||
// ModelPerformanceSummary 模型性能摘要
|
||
type ModelPerformanceSummary struct {
|
||
ModelName string `json:"model_name"`
|
||
RequestCount int `json:"request_count"`
|
||
SuccessCount int `json:"success_count"`
|
||
SuccessRate float64 `json:"success_rate"`
|
||
AvgLatencyMs float64 `json:"avg_latency_ms"`
|
||
AvgFirstTokenMs float64 `json:"avg_first_token_ms"`
|
||
TPS float64 `json:"tps"`
|
||
InputTokens int64 `json:"input_tokens"`
|
||
OutputTokens int64 `json:"output_tokens"`
|
||
TotalTokens int64 `json:"total_tokens"`
|
||
TotalCost float64 `json:"total_cost"`
|
||
CacheCreationTokens int64 `json:"cache_creation_tokens"`
|
||
CacheReadTokens int64 `json:"cache_read_tokens"`
|
||
CacheHitRequestCount int `json:"cache_hit_request_count"`
|
||
CacheHitRequestRate float64 `json:"cache_hit_request_rate"`
|
||
CacheHitRate float64 `json:"cache_hit_rate"`
|
||
Grade string `json:"grade"`
|
||
}
|
||
|
||
type MonitorModelChannelsReq struct {
|
||
g.Meta `path:"/monitor/model-channels" method:"get" mime:"json" tags:"管理后台-监控" summary:"模型各渠道性能"`
|
||
StartDate string `json:"start_date" in:"query"` // YYYY-MM-DD，缺省=近30天起点
|
||
EndDate string `json:"end_date" in:"query"` // YYYY-MM-DD，缺省=今天
|
||
ModelName string `json:"model_name" in:"query" v:"required" dc:"必填，待查询的模型名"`
|
||
}
|
||
|
||
type MonitorModelChannelsRes struct {
|
||
List []ModelChannelPerformance `json:"list"`
|
||
}
|
||
|
||
// ModelChannelPerformance 模型在各渠道的性能数据
|
||
type ModelChannelPerformance struct {
|
||
ChannelID int64 `json:"channel_id"`
|
||
ChannelName string `json:"channel_name"`
|
||
RequestCount int `json:"request_count"`
|
||
SuccessCount int `json:"success_count"`
|
||
SuccessRate float64 `json:"success_rate"`
|
||
AvgLatencyMs float64 `json:"avg_latency_ms"`
|
||
AvgFirstTokenMs float64 `json:"avg_first_token_ms"`
|
||
TPS float64 `json:"tps"`
|
||
CacheCreationTokens int64 `json:"cache_creation_tokens"`
|
||
CacheReadTokens int64 `json:"cache_read_tokens"`
|
||
CacheHitRequestCount int `json:"cache_hit_request_count"`
|
||
CacheHitRequestRate float64 `json:"cache_hit_request_rate"`
|
||
CacheHitRate float64 `json:"cache_hit_rate"`
|
||
}
|
||
|
||
type MonitorLatencyReq struct {
|
||
g.Meta `path:"/monitor/latency" method:"get" mime:"json" tags:"管理后台-监控" summary:"延迟直方图"`
|
||
Minutes int `json:"minutes" in:"query" d:"5"`
|
||
}
|
||
|
||
type MonitorLatencyRes struct {
|
||
Data map[string]any `json:"-"`
|
||
}
|
||
|
||
func (r *MonitorLatencyRes) MarshalJSON() ([]byte, error) {
|
||
return json.Marshal(r.Data)
|
||
}
|
||
|
||
type MonitorSystemReq struct {
|
||
g.Meta `path:"/monitor/system" method:"get" mime:"json" tags:"管理后台-监控" summary:"系统指标"`
|
||
Minutes int `json:"minutes" in:"query" d:"60"`
|
||
}
|
||
|
||
type MonitorSystemRes struct {
|
||
Data map[string]any `json:"-"`
|
||
}
|
||
|
||
func (r *MonitorSystemRes) MarshalJSON() ([]byte, error) {
|
||
return json.Marshal(r.Data)
|
||
}
|
||
|
||
// MonitorDispatchReq 渠道调度引擎指标请求
|
||
type MonitorDispatchReq struct {
|
||
g.Meta `path:"/monitor/dispatch" method:"get" mime:"json" tags:"管理后台-监控" summary:"调度引擎指标"`
|
||
Minutes int `json:"minutes" in:"query" d:"60" v:"between:5,10080" dc:"统计窗口（分钟）"`
|
||
}
|
||
|
||
// MonitorDispatchRes 渠道调度引擎指标响应。
|
||
// Latest 为进程启动以来的累计快照；Window 为窗口内增量（窗口首尾快照做差，
|
||
// 计数器因重启回绕时按 0 处理）。窗口内不足两条快照时 Window 为空。
|
||
type MonitorDispatchRes struct {
|
||
Available bool `json:"available" dc:"是否有指标数据"`
|
||
CollectedAt string `json:"collected_at,omitempty" dc:"最新快照时间"`
|
||
WindowMinutes int `json:"window_minutes" dc:"实际统计窗口（分钟）"`
|
||
Latest *DispatchMetricsData `json:"latest,omitempty" dc:"累计快照"`
|
||
Window *DispatchMetricsData `json:"window,omitempty" dc:"窗口增量"`
|
||
}
|
||
|
||
// DispatchMetricsData 调度指标数据（累计或增量）
|
||
type DispatchMetricsData struct {
|
||
Selections map[string]int64 `json:"selections" dc:"选择次数按原因（bind/hrw/overflow/probe/cred_rotate）"`
|
||
Retries map[string]int64 `json:"retries" dc:"重试决策按 错误类别→决策"`
|
||
OverflowByTier map[string]int64 `json:"overflow_by_tier" dc:"溢出次数按目标层级"`
|
||
SessionSources map[string]int64 `json:"session_sources" dc:"会话键来源分布（hdr/anthropic/openai/ident）"`
|
||
BreakerOpens int64 `json:"breaker_opens" dc:"熔断打开次数"`
|
||
NoCandidate int64 `json:"no_candidate" dc:"无可用渠道次数"`
|
||
}
|
||
|
||
type MonitorDBPoolReq struct {
|
||
g.Meta `path:"/monitor/db-pool" method:"get" mime:"json" tags:"管理后台-监控" summary:"数据库连接池"`
|
||
}
|
||
|
||
type MonitorDBPoolRes struct {
|
||
ActiveConnections int `json:"active_connections"`
|
||
IdleConnections int `json:"idle_connections"`
|
||
TotalConnections int `json:"total_connections"`
|
||
MaxConnections int `json:"max_connections"`
|
||
WaitingQueries int `json:"waiting_queries"`
|
||
}
|
||
|
||
type MonitorRedisPoolReq struct {
|
||
g.Meta `path:"/monitor/redis-pool" method:"get" mime:"json" tags:"管理后台-监控" summary:"Redis连接池"`
|
||
}
|
||
|
||
type MonitorRedisPoolRes struct {
|
||
ConnectedClients int `json:"connected_clients"`
|
||
UsedMemoryMB float64 `json:"used_memory_mb"`
|
||
MaxMemoryMB float64 `json:"max_memory_mb"`
|
||
UsedMemoryPercent float64 `json:"used_memory_percent"`
|
||
TotalCommands int64 `json:"total_commands"`
|
||
InstantaneousOps int64 `json:"instantaneous_ops"`
|
||
KeyspaceHits int64 `json:"keyspace_hits"`
|
||
KeyspaceMisses int64 `json:"keyspace_misses"`
|
||
HitRate float64 `json:"hit_rate"`
|
||
}
|
||
|
||
// === 实时监控 ===
|
||
|
||
type MonitorRealtimeReq struct {
|
||
g.Meta `path:"/monitor/realtime" method:"get" mime:"json" tags:"管理后台-监控" summary:"实时监控数据"`
|
||
}
|
||
|
||
type MonitorRealtimeRes struct {
|
||
Data any `json:"-"`
|
||
}
|
||
|
||
func (r *MonitorRealtimeRes) MarshalJSON() ([]byte, error) {
|
||
return json.Marshal(r.Data)
|
||
}
|
||
|
||
// === 告警规则 ===
|
||
|
||
type AlertRuleListReq struct {
|
||
g.Meta `path:"/alert/rules" method:"get" mime:"json" tags:"管理后台-告警" summary:"告警规则列表"`
|
||
Page int `json:"page" in:"query" d:"1"`
|
||
PageSize int `json:"page_size" in:"query" d:"20"`
|
||
MetricType string `json:"metric_type" in:"query"`
|
||
Level string `json:"level" in:"query"`
|
||
Enabled string `json:"enabled" in:"query"`
|
||
}
|
||
|
||
type AlertRuleListRes struct {
|
||
List []map[string]any `json:"list"`
|
||
Total int `json:"total"`
|
||
Page int `json:"page"`
|
||
PageSize int `json:"page_size"`
|
||
}
|
||
|
||
type AlertOptionsReq struct {
|
||
g.Meta `path:"/alert/options" method:"get" mime:"json" tags:"管理后台-告警" summary:"告警选项"`
|
||
}
|
||
|
||
type AlertOptionsRes struct {
|
||
Data map[string]any `json:"-"`
|
||
}
|
||
|
||
func (r *AlertOptionsRes) MarshalJSON() ([]byte, error) {
|
||
return json.Marshal(r.Data)
|
||
}
|
||
|
||
type AlertRuleCreateReq struct {
|
||
g.Meta `path:"/alert/rules" method:"post" mime:"json" tags:"管理后台-告警" summary:"创建告警规则"`
|
||
Name string `json:"name" v:"required"`
|
||
MetricType string `json:"metric_type" v:"required"`
|
||
Condition string `json:"condition" v:"required"`
|
||
Threshold float64 `json:"threshold" v:"required"`
|
||
DurationSeconds int `json:"duration_seconds"`
|
||
NotificationMethods []string `json:"notification_methods"`
|
||
WebhookURL string `json:"webhook_url"`
|
||
Level string `json:"level"`
|
||
CooldownSeconds int `json:"cooldown_seconds"`
|
||
NotifyUserIDs []int64 `json:"notify_user_ids"`
|
||
}
|
||
|
||
type AlertRuleCreateRes struct {
|
||
ID int64 `json:"id"`
|
||
}
|
||
|
||
type AlertRuleUpdateReq struct {
|
||
g.Meta `path:"/alert/rules/{id}" method:"put" mime:"json" tags:"管理后台-告警" summary:"更新告警规则"`
|
||
Id int64 `json:"id" in:"path" v:"required|min:1"`
|
||
Name string `json:"name"`
|
||
MetricType string `json:"metric_type"`
|
||
Condition string `json:"condition"`
|
||
Threshold *float64 `json:"threshold"`
|
||
DurationSeconds *int `json:"duration_seconds"`
|
||
NotificationMethods []string `json:"notification_methods"`
|
||
WebhookURL string `json:"webhook_url"`
|
||
Level string `json:"level"`
|
||
CooldownSeconds *int `json:"cooldown_seconds"`
|
||
NotifyUserIDs []int64 `json:"notify_user_ids"`
|
||
}
|
||
|
||
type AlertRuleUpdateRes struct{}
|
||
|
||
type AlertRuleDeleteReq struct {
|
||
g.Meta `path:"/alert/rules/{id}" method:"delete" mime:"json" tags:"管理后台-告警" summary:"删除告警规则"`
|
||
Id int64 `json:"id" in:"path" v:"required|min:1"`
|
||
}
|
||
|
||
type AlertRuleDeleteRes struct{}
|
||
|
||
type AlertRuleToggleReq struct {
|
||
g.Meta `path:"/alert/rules/{id}/toggle" method:"put" mime:"json" tags:"管理后台-告警" summary:"切换告警规则"`
|
||
Id int64 `json:"id" in:"path" v:"required|min:1"`
|
||
}
|
||
|
||
type AlertRuleToggleRes struct{}
|
||
|
||
type AlertTestReq struct {
|
||
g.Meta `path:"/alert/rules/{id}/test" method:"post" mime:"json" tags:"管理后台-告警" summary:"测试告警"`
|
||
Id int64 `json:"id" in:"path" v:"required|min:1"`
|
||
}
|
||
|
||
type AlertTestRes struct {
|
||
Message string `json:"message"`
|
||
}
|
||
|
||
// === 告警事件 ===
|
||
|
||
type AlertEventListReq struct {
|
||
g.Meta `path:"/alert/events" method:"get" mime:"json" tags:"管理后台-告警" summary:"告警事件列表"`
|
||
Page int `json:"page" in:"query" d:"1"`
|
||
PageSize int `json:"page_size" in:"query" d:"20"`
|
||
Status string `json:"status" in:"query"`
|
||
Level string `json:"level" in:"query"`
|
||
RuleID int64 `json:"rule_id" in:"query"`
|
||
}
|
||
|
||
type AlertEventListRes struct {
|
||
List []map[string]any `json:"list"`
|
||
Total int `json:"total"`
|
||
Page int `json:"page"`
|
||
PageSize int `json:"page_size"`
|
||
}
|
||
|
||
type AlertEventAcknowledgeReq struct {
|
||
g.Meta `path:"/alert/events/{id}/acknowledge" method:"put" mime:"json" tags:"管理后台-告警" summary:"确认告警"`
|
||
Id int64 `json:"id" in:"path" v:"required|min:1"`
|
||
}
|
||
|
||
type AlertEventAcknowledgeRes struct{}
|
||
|
||
type AlertEventResolveReq struct {
|
||
g.Meta `path:"/alert/events/{id}/resolve" method:"put" mime:"json" tags:"管理后台-告警" summary:"解决告警"`
|
||
Id int64 `json:"id" in:"path" v:"required|min:1"`
|
||
Notes string `json:"notes"`
|
||
}
|
||
|
||
type AlertEventResolveRes struct{}
|
||
|
||
// AlertEventClearReq 清空全部告警记录（硬删除，同时清理 Redis 中的触发状态）
|
||
type AlertEventClearReq struct {
|
||
g.Meta `path:"/alert/events/clear" method:"delete" mime:"json" tags:"管理后台-告警" summary:"清空告警记录（硬删除全部）"`
|
||
}
|
||
|
||
// AlertEventClearRes 清空告警记录响应
|
||
type AlertEventClearRes struct {
|
||
Deleted int64 `json:"deleted" dc:"删除的记录数"`
|
||
}
|