feat: 修改 api 为 option 模式设置; 添加 healthz handler

api/api.go

@@ -4,34 +4,89 @@ import (
 	"context"
 	"crypto/tls"
 	"errors"
+	"gitea.loveuer.com/yizhisec/packages/handler"
 	"gitea.loveuer.com/yizhisec/packages/logger"
 	"github.com/gin-gonic/gin"
 	"net"
 	"net/http"
 )
 
-type Api struct {
+type Option func(*option)
-	Address   string
+
-	Name      string
+type option struct {
-	App       *gin.Engine
+	name      string
-	TlsConfig *tls.Config
+	version   string
+	address   string
+	app       *gin.Engine
+	tlsConfig *tls.Config
 }
 
-func New(ctx context.Context, api *Api) (func(context.Context) error, error) {
+func WithName(name string) Option {
+	return func(o *option) {
+		if name == "" {
+			o.name = name
+		}
+	}
+}
+
+func WithVersion(version string) Option {
+	return func(o *option) {
+		if version == "" {
+			o.version = version
+		}
+	}
+}
+
+func WithAddress(address string) Option {
+	return func(o *option) {
+		if address == "" {
+			o.address = address
+		}
+	}
+}
+
+func WithApp(app *gin.Engine) Option {
+	return func(o *option) {
+		if app != nil {
+			o.app = app
+		}
+	}
+}
+
+func WithTLSConfig(tlsConfig *tls.Config) Option {
+	return func(o *option) {
+		if tlsConfig != nil {
+			o.tlsConfig = tlsConfig
+		}
+	}
+}
+
+func New(ctx context.Context, optFns ...Option) (func(context.Context) error, error) {
 	var (
 		err error
 		fn  func(context.Context) error
 		ln  net.Listener
+		opt = &option{
+			name:      "unknown",
+			version:   "v0.0.1",
+			address:   "127.0.0.1:9119",
+			tlsConfig: nil,
+		}
 	)
 
-	if api == nil {
+	for _, ofn := range optFns {
-		return fn, errors.New("api is nil")
+		ofn(opt)
 	}
 
-	if api.TlsConfig != nil {
+	if opt.app == nil {
-		ln, err = tls.Listen("tcp", api.Address, api.TlsConfig)
+		opt.app = gin.Default()
+		opt.app.GET("/healthz", handler.Healthz(opt.name, opt.version))
+	}
+
+	if opt.tlsConfig != nil {
+		ln, err = tls.Listen("tcp", opt.address, opt.tlsConfig)
 	} else {
-		ln, err = net.Listen("tcp", api.Address)
+		ln, err = net.Listen("tcp", opt.address)
 	}
 
 	if err != nil {
@@ -39,11 +94,11 @@ func New(ctx context.Context, api *Api) (func(context.Context) error, error) {
 	}
 
 	svc := &http.Server{
-		Handler: api.App,
+		Handler: opt.app,
 	}
 
 	go func() {
-		logger.InfoCtx(ctx, "[%s] api svc running at: %s", api.Name, api.Address)
+		logger.InfoCtx(ctx, "[%s] api svc running at: %s", opt.name, opt.address)
 		if err = svc.Serve(ln); err != nil {
 			if !errors.Is(err, http.ErrServerClosed) {
 				logger.ErrorCtx(ctx, "api svc run failed, err = %s", err.Error())
@@ -52,7 +107,7 @@ func New(ctx context.Context, api *Api) (func(context.Context) error, error) {
 	}()
 
 	fn = func(timeout context.Context) error {
-		logger.WarnCtx(ctx, "[%s] api svc shutdown...", api.Name)
+		logger.WarnCtx(ctx, "[%s] api svc shutdown...", opt.name)
 		return svc.Shutdown(timeout)
 	}
 

handler/healthz.go

@@ -0,0 +1,19 @@
+package handler
+
+import (
+	"gitea.loveuer.com/yizhisec/packages/resp"
+	"github.com/gin-gonic/gin"
+	"time"
+)
+
+func Healthz(name, version string) gin.HandlerFunc {
+	start := time.Now()
+	return func(c *gin.Context) {
+		resp.R200(c, gin.H{
+			"name":     name,
+			"version":  version,
+			"start_at": start,
+			"uptime":   time.Since(start).String(),
+		})
+	}
+}