如何在Golang中实现云原生监控面板_可视化指标和告警

import (
    "net/http"
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
)
<p>var (
httpRequestsTotal = prometheus.NewCounterVec(
prometheus.CounterOpts{
Name: "http_requests_total",
Help: "Total number of HTTP requests.",
},
[]string{"method", "status"},
)
httpRequestDuration = prometheus.NewHistogramVec(
prometheus.HistogramOpts{
Name:    "http_request_duration_seconds",
Help:    "HTTP request duration in seconds.",
Buckets: prometheus.DefBuckets,
},
[]string{"handler"},
)
)</p><p>func init() {
prometheus.MustRegister(httpRequestsTotal, httpRequestDuration)
}

func handler(w http.ResponseWriter, r *http.Request) {
    start := time.Now()
    defer func() {
        httpRequestDuration.WithLabelValues(r.URL.Path).Observe(time.Since(start).Seconds())
        httpRequestsTotal.WithLabelValues(r.Method, strconv.Itoa(http.StatusOK)).Inc()
    }()
    // 实际业务逻辑...
}

http.Handle("/metrics", promhttp.Handler())
http.ListenAndServe(":8080", nil)

scrape_configs:
  - job_name: 'go-app'
    static_configs:
      - targets: ['go-app-service:8080']  # Kubernetes 中可用 Service DNS 名
    metrics_path: '/metrics'

type AlertWebhook struct {
    URL string
}
<p>func (a *AlertWebhook) Send(title, desc, severity string) error {
payload := map[string]interface{}{
"title":       title,
"text":        desc,
"severity":    severity,
"timestamp":   time.Now().UTC().Format(time.RFC3339),
}
data, _ := json.Marshal(payload)
resp, err := http.Post(a.URL, "application/json", bytes.NewBuffer(data))
if err != nil {
return err
}
defer resp.Body.Close()
return nil
}

if failureRate > 0.1 {
    alert.Send("High DB Failure Rate", "DB error rate > 10% in last minute", "critical")
}