dashboard

type Aggregator struct {
	// contains filtered or unexported fields
}

type CostAmount struct {
	Amount   float64 `json:"amount"`
	Currency string  `json:"currency"`
}

type CostBreakdown struct {
	Period  string                `json:"period"`
	Total   CostAmount            `json:"total"`
	ByAgent map[string]CostAmount `json:"by_agent,omitempty"`
	ByModel map[string]CostAmount `json:"by_model,omitempty"`
	Trend   []CostTrendPoint      `json:"trend,omitempty"`
}

type CostCalculator struct {
	// contains filtered or unexported fields
}

type CostQueryOpts struct {
	Period    string     `json:"period"`
	StartTime *time.Time `json:"start_time,omitempty"`
	EndTime   *time.Time `json:"end_time,omitempty"`
	AgentID   string     `json:"agent_id,omitempty"`
}

type CostTrendPoint struct {
	Timestamp time.Time `json:"timestamp"`
	Amount    float64   `json:"amount"`
}

type DetailedCost struct {
	Model        string       `json:"model"`
	InputTokens  int64        `json:"input_tokens"`
	OutputTokens int64        `json:"output_tokens"`
	InputCost    CostAmount   `json:"input_cost"`
	OutputCost   CostAmount   `json:"output_cost"`
	TotalCost    CostAmount   `json:"total_cost"`
	Pricing      ModelPricing `json:"pricing"`
}

type EventBusProvider interface {
	GetEventBuses() []*events.EventBus
}

type EventStreamMessage struct {
	Type      string    `json:"type"` // "event", "heartbeat", "error"
	Channel   string    `json:"channel,omitempty"`
	Event     any       `json:"event,omitempty"`
	Timestamp time.Time `json:"timestamp"`
	Error     string    `json:"error,omitempty"`
}

type EventSubscription struct {
	Channels   []string `json:"channels"` // "monitor", "progress", "control"
	AgentID    string   `json:"agent_id,omitempty"`
	EventTypes []string `json:"event_types,omitempty"`
}

type Insight struct {
	ID          string         `json:"id"`
	Type        InsightType    `json:"type"`
	Severity    string         `json:"severity"` // "info", "warning", "critical"
	Title       string         `json:"title"`
	Description string         `json:"description"`
	Suggestion  string         `json:"suggestion"`
	Data        map[string]any `json:"data,omitempty"`
	CreatedAt   time.Time      `json:"created_at"`
}

type InsightType string

type LatencyPercentiles struct {
	P50 int64 `json:"p50"`
	P95 int64 `json:"p95"`
	P99 int64 `json:"p99"`
	Avg int64 `json:"avg"`
	Max int64 `json:"max"`
}

type ModelPricing struct {
	Model           string  `json:"model"`
	InputPricePerM  float64 `json:"input_price_per_m"`  // 每百万 token 价格
	OutputPricePerM float64 `json:"output_price_per_m"` // 每百万 token 价格
	Currency        string  `json:"currency"`
}

type OverviewStats struct {
	ActiveAgents   int        `json:"active_agents"`
	ActiveSessions int        `json:"active_sessions"`
	TotalRequests  int64      `json:"total_requests"`
	TokenUsage     TokenCount `json:"token_usage"`
	Cost           CostAmount `json:"cost"`
	ErrorRate      float64    `json:"error_rate"`
	AvgLatencyMs   int64      `json:"avg_latency_ms"`
	Period         string     `json:"period"` // "24h", "7d", "30d"
	UpdatedAt      time.Time  `json:"updated_at"`
}

type PerformanceStats struct {
	Period       string                        `json:"period"`
	TTFT         LatencyPercentiles            `json:"ttft"`           // Time to First Token
	TPOT         LatencyPercentiles            `json:"tpot"`           // Time Per Output Token
	ToolLatency  map[string]LatencyPercentiles `json:"tool_latency"`   // 按工具
	AvgLoopCount float64                       `json:"avg_loop_count"` // 平均循环次数
	RequestCount int64                         `json:"request_count"`
	ErrorCount   int64                         `json:"error_count"`
	ErrorRate    float64                       `json:"error_rate"`
}

type SessionTimeline struct {
	SessionID string                 `json:"session_id"`
	AgentID   string                 `json:"agent_id"`
	Entries   []SessionTimelineEntry `json:"entries"`
	StartTime time.Time              `json:"start_time"`
	EndTime   *time.Time             `json:"end_time,omitempty"`
}

type SessionTimelineEntry struct {
	Timestamp time.Time `json:"timestamp"`
	Type      string    `json:"type"` // "message", "tool_call", "checkpoint", "error"
	Data      any       `json:"data"`
}

type TokenCount struct {
	Input  int64 `json:"input"`
	Output int64 `json:"output"`
	Total  int64 `json:"total"`
}

type TokenQueryOpts struct {
	Period    string     `json:"period"` // "hour", "day", "week", "month"
	StartTime *time.Time `json:"start_time,omitempty"`
	EndTime   *time.Time `json:"end_time,omitempty"`
	AgentID   string     `json:"agent_id,omitempty"`
	Model     string     `json:"model,omitempty"`
}

type TokenTrendPoint struct {
	Timestamp time.Time `json:"timestamp"`
	Input     int64     `json:"input"`
	Output    int64     `json:"output"`
}

type TokenUsageStats struct {
	Period  string                `json:"period"` // "hour", "day", "week", "month"
	Total   TokenCount            `json:"total"`
	ByAgent map[string]TokenCount `json:"by_agent,omitempty"`
	ByModel map[string]TokenCount `json:"by_model,omitempty"`
	Trend   []TokenTrendPoint     `json:"trend,omitempty"`
	Cost    CostAmount            `json:"cost"`
}

type TokenUsageWithModel struct {
	Model        string `json:"model"`
	InputTokens  int64  `json:"input_tokens"`
	OutputTokens int64  `json:"output_tokens"`
}

type TraceBuilder struct {
	// contains filtered or unexported fields
}

type TraceDetail struct {
	TraceSummary

	RootSpan   *TraceNode `json:"root_span"`
	TokenUsage TokenCount `json:"token_usage"`
	Cost       CostAmount `json:"cost"`
}

type TraceListResult struct {
	Traces  []*TraceSummary `json:"traces"`
	Total   int64           `json:"total"`
	HasMore bool            `json:"has_more"`
}

type TraceNode struct {
	ID         string         `json:"id"`
	Name       string         `json:"name"`
	Type       TraceNodeType  `json:"type"`
	StartTime  time.Time      `json:"start_time"`
	EndTime    *time.Time     `json:"end_time,omitempty"`
	DurationMs int64          `json:"duration_ms"`
	Status     TraceStatus    `json:"status"`
	Attributes map[string]any `json:"attributes,omitempty"`
	Children   []*TraceNode   `json:"children,omitempty"`
}

type TraceNodeType string

type TraceQueryOpts struct {
	StartTime *time.Time `json:"start_time,omitempty"`
	EndTime   *time.Time `json:"end_time,omitempty"`
	AgentID   string     `json:"agent_id,omitempty"`
	Status    string     `json:"status,omitempty"`
	Limit     int        `json:"limit,omitempty"`
	Offset    int        `json:"offset,omitempty"`
}

type TraceStatus string

type TraceSummary struct {
	ID           string      `json:"id"`
	Name         string      `json:"name"`
	AgentID      string      `json:"agent_id,omitempty"`
	AgentName    string      `json:"agent_name,omitempty"`
	StartTime    time.Time   `json:"start_time"`
	DurationMs   int64       `json:"duration_ms"`
	Status       TraceStatus `json:"status"`
	SpanCount    int         `json:"span_count"`
	TokenUsage   TokenCount  `json:"token_usage"`
	ErrorMessage string      `json:"error_message,omitempty"`
}