logan
9f7c522157
- kubernetes/: 30Gi PVC、单副本 Recreate、Secret/Service/NodePort/Ingress 清单与部署文档 - 数据安全: kubeconfig/token 统一加密存储，启动迁移历史明文，DB 0600 - Token 接入: 命名空间级最小权限提示、长期 Token、自签证书 TLS 兼容 - 部署: 命名空间级 Token 下跳过 Namespace patch/枚举，节点信息容错 - 日志页: namespace → app → pod 选择顺序与作用域收窄 - 设置页: 拆分为通用/告警/LDAP/镜像源四个 tab - 弹框: 统一 max-h 滚动与长命令换行，修复内容溢出
78 lines
2.1 KiB
Go
78 lines
2.1 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"log"
|
|
"net/http"
|
|
"os/signal"
|
|
"syscall"
|
|
"time"
|
|
|
|
"opsxloki/config"
|
|
"opsxloki/repository"
|
|
"opsxloki/routers"
|
|
"opsxloki/seed"
|
|
"opsxloki/services"
|
|
)
|
|
|
|
func main() {
|
|
cfg := config.GetConfig()
|
|
|
|
log.Println("Initializing database...")
|
|
if err := repository.InitDB(); err != nil {
|
|
log.Fatalf("Failed to init DB: %v", err)
|
|
}
|
|
|
|
log.Println("Seeding default data...")
|
|
seed.Seed()
|
|
|
|
// 安全迁移：历史明文 kubeconfig → 加密存储，并清理明文文件
|
|
services.MigrateClusterKubeconfigs()
|
|
|
|
// 孤儿部署状态恢复:进程重启会杀掉进行中的部署 goroutine,
|
|
// 残留的 "deploying" 状态将永远卡住(UI 无停止入口),启动时统一标记为失败。
|
|
repository.GetDB().RecoverOrphanDeployments()
|
|
|
|
services.StartAlertEngine()
|
|
defer services.StopAlertEngine()
|
|
|
|
r := routers.SetupRouter()
|
|
srv := &http.Server{
|
|
Addr: ":" + cfg.ServerPort,
|
|
Handler: r,
|
|
ReadTimeout: 30 * time.Second,
|
|
WriteTimeout: 130 * time.Second,
|
|
IdleTimeout: 120 * time.Second,
|
|
}
|
|
|
|
// 监听中断/终止信号，实现优雅关停：先停 HTTP（拒绝新请求、处理完在途请求），
|
|
// 再 flush 数据库，避免防抖/异步保存丢失最近写入。
|
|
ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
|
|
defer stop()
|
|
|
|
go func() {
|
|
log.Printf("opsx-loki starting on port %s", cfg.ServerPort)
|
|
log.Printf("API: http://localhost:%s/api/v1", cfg.ServerPort)
|
|
log.Printf("Default login: admin / admin123")
|
|
if err := srv.ListenAndServe(); err != nil && !errors.Is(err, http.ErrServerClosed) {
|
|
log.Fatalf("Server failed: %v", err)
|
|
}
|
|
}()
|
|
|
|
<-ctx.Done()
|
|
log.Println("Shutdown signal received, draining connections...")
|
|
|
|
shutdownCtx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
|
|
defer cancel()
|
|
if err := srv.Shutdown(shutdownCtx); err != nil {
|
|
log.Printf("HTTP shutdown error: %v", err)
|
|
}
|
|
|
|
log.Println("Flushing database...")
|
|
if err := repository.Shutdown(); err != nil {
|
|
log.Printf("DB shutdown error: %v", err)
|
|
}
|
|
log.Println("LokiDeploy stopped")
|
|
}
|