package main
<p>import (
"net/http"
"time"
)</p><p>func healthz(w http.ResponseWriter, r *http.Request) {
// 可在此加入数据库连接、依赖服务等检查
w.WriteHeader(http.StatusOK)
w.Write([]byte("OK"))
}</p><p>func main() {
mux := http.NewServeMux()
mux.HandleFunc("/healthz", healthz)</p><pre class='brush:php;toolbar:false;'>server := &http.Server{
    Addr:         ":8080",
    Handler:      mux,
    ReadTimeout:  5 * time.Second,
    WriteTimeout: 5 * time.Second,
}

server.ListenAndServe()

}

apiVersion: v1
kind: Pod
metadata:
  name: go-app
spec:
  containers:
  - name: go-container
    image: my-go-app:latest
    ports:
    - containerPort: 8080
    livenessProbe:
      httpGet:
        path: /healthz
        port: 8080
      initialDelaySeconds: 10
      periodSeconds: 10
      timeoutSeconds: 3
      failureThreshold: 3
    readinessProbe:
      httpGet:
        path: /healthz
        port: 8080
      initialDelaySeconds: 5
      periodSeconds: 5

func healthz(db *sql.DB) http.HandlerFunc {
    return func(w http.ResponseWriter, r *http.Request) {
        ctx, cancel := context.WithTimeout(r.Context(), 2*time.Second)
        defer cancel()
<pre class='brush:php;toolbar:false;'>    if err := db.PingContext(ctx); err != nil {
        http.Error(w, "DB unreachable", http.StatusServiceUn*ailable)
        return
    }

    w.Write([]byte("OK"))
}

}