metrics

type AgentMetrics struct {
	AgentStats   map[string]*AgentStat `json:"agent_stats"`
	ErrorsByType map[string]int64      `json:"errors_by_type"`
	RequestCount int64                 `json:"request_count"`
	SuccessCount int64                 `json:"success_count"`
	LatencyP50   time.Duration         `json:"latency_p50"`
	LatencyP95   time.Duration         `json:"latency_p95"`
}

type AgentSnapshot struct {
	HourBucket   time.Time
	AgentType    string
	RequestCount int64
	SuccessCount int64
	LatencySumMs int64
	LatencyP50Ms int32
	LatencyP95Ms int32
}

type AgentStat struct {
	Count       int64         `json:"count"`
	SuccessRate float32       `json:"success_rate"`
	AvgLatency  time.Duration `json:"avg_latency"`
}

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

type MetricsService interface {
	// RecordRequest records request metrics.
	RecordRequest(ctx context.Context, agentType string, latency time.Duration, success bool)

	// RecordToolCall records tool call metrics.
	RecordToolCall(ctx context.Context, toolName string, latency time.Duration, success bool)

	// GetStats retrieves statistics data.
	GetStats(ctx context.Context, timeRange TimeRange) (*AgentMetrics, error)
}

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

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

type PersisterConfig struct {
	FlushInterval   time.Duration // How often to flush metrics to DB (default: 1 hour)
	RetentionPeriod time.Duration // How long to keep metrics (default: 30 days)
	CleanupInterval time.Duration // How often to run cleanup (default: 24 hours)
}

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

type TimeRange struct {
	Start time.Time `json:"start"`
	End   time.Time `json:"end"`
}

type ToolSnapshot struct {
	HourBucket   time.Time
	ToolName     string
	CallCount    int64
	SuccessCount int64
	LatencySumMs int64
}