diff --git a/internal/storage/retention.go b/internal/storage/retention.go index 24effe7..0733695 100644 --- a/internal/storage/retention.go +++ b/internal/storage/retention.go @@ -400,26 +400,44 @@ func (r *RetentionScheduler) runMaintenance(ctx context.Context) { } } + // Maintenance commands use literal SQL per table — no fmt.Sprintf — so static + // analyzers don't have to taint-track that the table names are hardcoded. + type maintCmd struct { + table string + sql string + } switch driver { case "postgres", "postgresql": - for _, t := range []string{"logs", "spans", "traces", "metric_buckets"} { + cmds := []maintCmd{ + {"logs", "VACUUM ANALYZE logs"}, + {"spans", "VACUUM ANALYZE spans"}, + {"traces", "VACUUM ANALYZE traces"}, + {"metric_buckets", "VACUUM ANALYZE metric_buckets"}, + } + for _, c := range cmds { start := time.Now() - if _, err := sqlDB.ExecContext(ctx, fmt.Sprintf("VACUUM ANALYZE %s", t)); err != nil { - slog.Error("retention: VACUUM ANALYZE failed", "table", t, "error", err) + if _, err := sqlDB.ExecContext(ctx, c.sql); err != nil { + slog.Error("retention: VACUUM ANALYZE failed", "table", c.table, "error", err) maintFailed = true } - observe(t, time.Since(start)) + observe(c.table, time.Since(start)) } case "mysql": // OPTIMIZE TABLE can run through the gorm handle (no tx restriction). db := r.repo.db.WithContext(ctx) - for _, t := range []string{"logs", "spans", "traces", "metric_buckets"} { + cmds := []maintCmd{ + {"logs", "OPTIMIZE TABLE logs"}, + {"spans", "OPTIMIZE TABLE spans"}, + {"traces", "OPTIMIZE TABLE traces"}, + {"metric_buckets", "OPTIMIZE TABLE metric_buckets"}, + } + for _, c := range cmds { start := time.Now() - if err := db.Exec(fmt.Sprintf("OPTIMIZE TABLE %s", t)).Error; err != nil { - slog.Error("retention: OPTIMIZE TABLE failed", "table", t, "error", err) + if err := db.Exec(c.sql).Error; err != nil { + slog.Error("retention: OPTIMIZE TABLE failed", "table", c.table, "error", err) maintFailed = true } - observe(t, time.Since(start)) + observe(c.table, time.Since(start)) } case "sqlite": start := time.Now() diff --git a/internal/ui/templates/base.html b/internal/ui/templates/base.html deleted file mode 100644 index d81979f..0000000 --- a/internal/ui/templates/base.html +++ /dev/null @@ -1,60 +0,0 @@ -{{ define "base" }} - - - - - - {{ .Title }} - - - - - - - - - - -
- {{ template "content" . }} -
- - -{{ end }} - diff --git a/internal/ui/templates/dashboard.html b/internal/ui/templates/dashboard.html deleted file mode 100644 index ee9859e..0000000 --- a/internal/ui/templates/dashboard.html +++ /dev/null @@ -1,154 +0,0 @@ -{{template "header" .}} - - - -
- - -
-
-
Total Logs
-
{{fmt_num .Stats.LogCount}}
-
log entries stored
-
-
-
Total Traces
-
{{fmt_num .Stats.TraceCount}}
-
distributed traces
-
-
-
Services
-
{{fmt_num .Stats.ServiceCount}}
-
unique services tracked
-
-
-
Error Logs
-
{{fmt_num (index .Stats "ErrorCount")}}
-
ERROR severity entries
-
-
- - -
-
-
Ingestion Rate
-
{{fmt_num .HealthStats.IngestionRate}}ev/s
-
telemetry events per second
-
-
-
DB Write Latency
-
{{printf "%.2f" .HealthStats.DBLatencyP99Ms}}ms
-
p99 write latency
-
-
-
Heap Memory
-
{{printf "%.1f" .HealthStats.HeapAllocMB}}MB
-
Go heap allocated
-
-
-
Database Size
-
{{.Stats.DBSizeMB}}MB
-
hot storage on disk
-
-
- - -
-
- Runtime - Prometheus → -
-
-
-
Uptime
-
{{fmt_num .HealthStats.UptimeSeconds}} s
-
process uptime
-
-
-
Goroutines
-
{{fmt_num .HealthStats.Goroutines}}
-
active goroutines
-
-
-
WS Conns
-
{{fmt_num .HealthStats.ActiveConns}}
-
websocket clients
-
-
-
DLQ
-
{{fmt_num .HealthStats.DLQSize}} files
-
dead letter queue
-
-
-
DB Driver
-
sqlite
-
relational backend
-
-
-
- - -
-
-
- Quick Actions -
-
- -
-
- -
- Service Topology -
- → - - -
-
- -
- MCP Console -
- → - -
-
- -
-
-
- OtelContext MCP - {{if .MCPEnabled}}LIVE{{end}} -
-

- Telemetry exposed directly to Language Models via the Model Context Protocol. Connect any AI agent to observe exactly what OtelContext sees. -

-
-
- {{if .MCPEnabled}}POST http://localhost:8080{{.MCPPath}}{{else}}MCP disabled — set MCP_ENABLED=true{{end}} -
-
-
- -
- -{{template "footer" .}} - diff --git a/internal/ui/templates/footer.html b/internal/ui/templates/footer.html deleted file mode 100644 index ecff17d..0000000 --- a/internal/ui/templates/footer.html +++ /dev/null @@ -1,6 +0,0 @@ -{{define "footer"}} - - - - -{{end}} diff --git a/internal/ui/templates/header.html b/internal/ui/templates/header.html deleted file mode 100644 index 465bd3f..0000000 --- a/internal/ui/templates/header.html +++ /dev/null @@ -1,141 +0,0 @@ -{{define "header"}} - - - - - - {{.Title}} - - - - - - - - - - -
-
- - -{{end}} - diff --git a/internal/ui/templates/index.html b/internal/ui/templates/index.html deleted file mode 100644 index d0aaa0a..0000000 --- a/internal/ui/templates/index.html +++ /dev/null @@ -1,49 +0,0 @@ -{{ template "base" . }} - -{{ define "content" }} -
-
-

Overview

-

Real-time telemetry and observability metrics.

-
- -
-
-
-

Total Traces

-
- -
-
-
{{ .Stats.TotalTraces }}
-
-
-
-

Total Logs

-
- -
-
-
{{ .Stats.TotalLogs }}
-
-
-
-

Time Series

-
- -
-
-
{{ .Stats.TotalTimeSeries }}
-
-
-
-

Storage Used

-
- -
-
-
{{ printf "%.2f" .Stats.DBSizeMb }} MB
-
-
-
-{{ end }} diff --git a/internal/ui/templates/logs.html b/internal/ui/templates/logs.html deleted file mode 100644 index 05e01f8..0000000 --- a/internal/ui/templates/logs.html +++ /dev/null @@ -1,47 +0,0 @@ -{{template "header" .}} - -
-
-

Log Explorer

-
- - -
-
- -
- - - - - - - - - - - {{range .Logs}} - - - - - - - {{else}} - - - - {{end}} - -
TimestampLevelServiceMessage
{{.Timestamp.Format "2006-01-02 15:04:05"}} - - {{.Severity}} - - {{.ServiceName}}{{.Body}}
No logs found
-
-
- -{{template "footer" .}} diff --git a/internal/ui/templates/mcp_console.html b/internal/ui/templates/mcp_console.html deleted file mode 100644 index 9e56362..0000000 --- a/internal/ui/templates/mcp_console.html +++ /dev/null @@ -1,555 +0,0 @@ -{{template "header" .}} - - - -
- - -
-
- - Connecting… -
-
- Endpoint: - -
- HTTP Streamable MCP · JSON-RPC 2.0 - -
- -
- - -
- - - -
-
- - -
-
- Available Tools - — -
-
-
Loading tools…
-
-
- -
- - - - - - - - - - - - -{{template "footer" .}} - diff --git a/internal/ui/templates/metrics.html b/internal/ui/templates/metrics.html deleted file mode 100644 index ecf1287..0000000 --- a/internal/ui/templates/metrics.html +++ /dev/null @@ -1,55 +0,0 @@ -{{template "header" .}} - -
- -
-
-

Ingestion Rate

-

{{printf "%.0f" .HealthStats.IngestionRate}}/s

-
-
-

DB Latency P99

-

{{printf "%.2f" .HealthStats.DBLatencyP99Ms}} ms

-
-
-

Heap Alloc

-

{{printf "%.1f" .HealthStats.HeapAllocMB}} MB

-
-
-

Goroutines

-

{{.HealthStats.Goroutines}}

-
-
- - -
-
-

Runtime Metrics

- Raw Prometheus → -
-
-
- Uptime - {{.HealthStats.UptimeSeconds}} seconds -
-
- Active WebSocket Connections - {{.HealthStats.ActiveConns}} -
-
- DLQ Queue Size - {{.HealthStats.DLQSize}} files -
-
- Goroutines - {{.HealthStats.Goroutines}} -
-
- Heap Allocated - {{printf "%.2f" .HealthStats.HeapAllocMB}} MB -
-
-
-
- -{{template "footer" .}} diff --git a/internal/ui/templates/services.html b/internal/ui/templates/services.html deleted file mode 100644 index 530e77f..0000000 --- a/internal/ui/templates/services.html +++ /dev/null @@ -1,518 +0,0 @@ -{{template "header" .}} - - - -
- - -
- - -
- -
- - - - -
- - -
- - - - -
- -
- - -
- Health — - Services — - Latency — - Errors — -
- - — - Loading… - - -
- - - -
- -
- - -
- - - - - -
-
Healthy
-
Degraded
-
Critical
-
Scroll to zoom · Drag to pan
-
- - -
100%
-
-
-
- - - - - - -{{template "footer" .}} diff --git a/internal/ui/templates/storage.html b/internal/ui/templates/storage.html deleted file mode 100644 index bce326d..0000000 --- a/internal/ui/templates/storage.html +++ /dev/null @@ -1,50 +0,0 @@ -{{template "header" .}} - -
- -
-
-

Total Traces

-

{{index .Stats "trace_count"}}

-
-
-

Error Logs

-

{{index .Stats "error_count"}}

-
-
-

Heap Used

-

{{printf "%.1f" .HealthStats.HeapAllocMB}} MB

-
-
-

DB Latency P99

-

{{printf "%.2f" .HealthStats.DBLatencyP99Ms}} ms

-
-
- - -
-
-

Runtime Health

-
-
-
-

Uptime

-

{{.HealthStats.UptimeSeconds}}s

-
-
-

Goroutines

-

{{.HealthStats.Goroutines}}

-
-
-

Active Connections

-

{{.HealthStats.ActiveConns}}

-
-
-

DLQ Size

-

{{.HealthStats.DLQSize}} files

-
-
-
-
- -{{template "footer" .}} diff --git a/internal/ui/templates/trace_detail.html b/internal/ui/templates/trace_detail.html deleted file mode 100644 index 6d94478..0000000 --- a/internal/ui/templates/trace_detail.html +++ /dev/null @@ -1,46 +0,0 @@ -{{template "header" .}} - -
-
-
-

Trace: {{.Trace.TraceID}}

-

{{.Trace.Name}} · {{.Trace.Duration}} · {{.Trace.StartTime.Format "2006-01-02 15:04:05.000"}}

-
- ← Back to Traces -
- -
-

Spans

-
- {{range .Spans}} -
-
-
-
- {{.Name}} - {{.SpanID}} -
- {{.Duration}} -
-
- Service: {{.ServiceName}} -
- - {{if .Tags}} -
- {{range $k, $v := .Tags}} - - {{$k}}: {{$v}} - - {{end}} -
- {{end}} -
- {{else}} -
No spans found for this trace.
- {{end}} -
-
-
- -{{template "footer" .}} diff --git a/internal/ui/templates/traces.html b/internal/ui/templates/traces.html deleted file mode 100644 index 166e42a..0000000 --- a/internal/ui/templates/traces.html +++ /dev/null @@ -1,42 +0,0 @@ -{{template "header" .}} - -
-
-

Recent Traces

-
- -
- - - - - - - - - - - - - {{range .Traces}} - - - - - - - - - {{else}} - - - - {{end}} - -
Trace IDRoot ServiceRoot NameStart TimeDurationAction
{{.TraceID}}{{.ServiceName}}{{.Name}}{{.StartTime.Format "15:04:05.000"}}{{.Duration}} - View Details -
No traces found
-
-
- -{{template "footer" .}} diff --git a/internal/ui/ui.go b/internal/ui/ui.go index f051e55..5960740 100644 --- a/internal/ui/ui.go +++ b/internal/ui/ui.go @@ -3,7 +3,6 @@ package ui import ( "embed" "fmt" - "html/template" "io/fs" "net/http" "strings" @@ -14,7 +13,7 @@ import ( "github.com/RandomCodeSpace/otelcontext/internal/vectordb" ) -//go:embed templates/*.html static/* dist +//go:embed static/* dist var content embed.FS type Server struct { @@ -22,54 +21,16 @@ type Server struct { metrics *telemetry.Metrics topo *graph.Graph vidx *vectordb.Index - tmpl *template.Template mcpEnabled bool mcpPath string } -// fmtNum formats an integer-like value with K / M / B suffix. -func fmtNum(v any) string { - var n float64 - switch val := v.(type) { - case int: - n = float64(val) - case int32: - n = float64(val) - case int64: - n = float64(val) - case float64: - n = val - case float32: - n = float64(val) - default: - return fmt.Sprintf("%v", v) - } - switch { - case n >= 1_000_000_000: - return fmt.Sprintf("%.2fB", n/1_000_000_000) - case n >= 1_000_000: - return fmt.Sprintf("%.2fM", n/1_000_000) - case n >= 1_000: - return fmt.Sprintf("%.1fK", n/1_000) - default: - return fmt.Sprintf("%.0f", n) - } -} - func NewServer(repo *storage.Repository, metrics *telemetry.Metrics, topo *graph.Graph, vidx *vectordb.Index) *Server { - tmpl := template.New("OtelContext").Funcs(template.FuncMap{ - "text_uppercase": strings.ToUpper, - "text_lowercase": strings.ToLower, - "fmt_num": fmtNum, - }) - tmpl = template.Must(tmpl.ParseFS(content, "templates/*.html")) - return &Server{ repo: repo, metrics: metrics, topo: topo, vidx: vidx, - tmpl: tmpl, mcpPath: "/mcp", } }