admin
db83db383c
Critical: watchdog mutex panic safety, SetGeoAppOverride nil guard, SSD-only app DB restore fallback. High: double deploy race (atomic Deploying flag), delete/remove during deploy guard, ScanStacks overwrite protection, FileBrowser mount mutex, PushEvent history, PushOnce error handling, DB dump sync+close before rename, restic retry fresh context, encrypt failure logging, cross-backup path traversal validation, deepCopyStack completeness. Security: constant-time API key comparison, login rate limiting (5/min), git credential masking in logs, storage path prefix traversal fix. Concurrency: MigrateEncryption lock ordering, SubdomainInUse I/O outside lock, scheduler late-registered jobs, SQLite WAL verification, metrics shutdown context, telemetry scan error logging, asset sync lock scope. Optimization: streaming file copy for DB dumps, restic stats dedup, atomic infra config copy. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
69 lines
1.8 KiB
Go
69 lines
1.8 KiB
Go
package metrics
|
|
|
|
import (
|
|
"log"
|
|
"time"
|
|
)
|
|
|
|
// ContainerTelemetry holds aggregated resource stats for one container.
|
|
type ContainerTelemetry struct {
|
|
ContainerName string `json:"container_name"`
|
|
MemoryCurrentMB float64 `json:"memory_current_mb"`
|
|
MemoryAvgMB float64 `json:"memory_avg_mb"`
|
|
MemoryPeakMB float64 `json:"memory_peak_mb"`
|
|
CPUAvgPercent float64 `json:"cpu_avg_percent"`
|
|
SampleCount int `json:"sample_count"`
|
|
}
|
|
|
|
// GetContainerTelemetry queries the metrics DB for per-container resource
|
|
// summaries since the given time. Returns empty slice (not error) if no data.
|
|
func (s *MetricsStore) GetContainerTelemetry(since time.Time) ([]ContainerTelemetry, error) {
|
|
sinceUnix := since.Unix()
|
|
|
|
rows, err := s.db.Query(`
|
|
SELECT container_name,
|
|
AVG(mem_usage_mb),
|
|
MAX(mem_usage_mb),
|
|
AVG(cpu_percent),
|
|
COUNT(*)
|
|
FROM container_metrics
|
|
WHERE ts > ?
|
|
GROUP BY container_name`, sinceUnix)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
|
|
var results []ContainerTelemetry
|
|
for rows.Next() {
|
|
var ct ContainerTelemetry
|
|
if err := rows.Scan(&ct.ContainerName, &ct.MemoryAvgMB, &ct.MemoryPeakMB,
|
|
&ct.CPUAvgPercent, &ct.SampleCount); err != nil {
|
|
log.Printf("[WARN] telemetry row scan failed: %v", err)
|
|
continue
|
|
}
|
|
results = append(results, ct)
|
|
}
|
|
if err := rows.Err(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Get current (most recent) memory per container
|
|
if stats, err := s.QueryContainerSummary(); err == nil {
|
|
currentMap := make(map[string]float64, len(stats))
|
|
for _, st := range stats {
|
|
currentMap[st.ContainerName] = st.MemUsageMB
|
|
}
|
|
for i := range results {
|
|
if cur, ok := currentMap[results[i].ContainerName]; ok {
|
|
results[i].MemoryCurrentMB = cur
|
|
}
|
|
}
|
|
}
|
|
|
|
if results == nil {
|
|
results = []ContainerTelemetry{}
|
|
}
|
|
return results, nil
|
|
}
|