feat: configAPI support return config version (#265)

Co-authored-by: evelynwei <[email protected]>

Author: peerless1024

examples/configuration/normal/main.go

@@ -19,15 +19,33 @@ package main
 
 import (
 	"encoding/json"
+	"flag"
+	"fmt"
 	"log"
 
 	"github.com/polarismesh/polaris-go"
+	"github.com/polarismesh/polaris-go/api"
 	"github.com/polarismesh/polaris-go/pkg/model"
 )
 
+var debug bool
+
+func initArgs() {
+	flag.BoolVar(&debug, "debug", true, "是否开启调试模式")
+}
+
 func main() {
+	initArgs()
+	flag.Parse()
 	log.Println("开始启动配置文件监听示例...")
-
+	if debug {
+		// 设置日志级别为DEBUG
+		if err := api.SetLoggersLevel(api.DebugLog); err != nil {
+			log.Printf("fail to set log level to DEBUG, err is %v", err)
+		} else {
+			log.Printf("successfully set log level to DEBUG")
+		}
+	}
 	configAPI, err := polaris.NewConfigAPI()
 	if err != nil {
 		log.Printf("创建配置API失败: %v", err)
@@ -53,6 +71,7 @@ func main() {
 	content := configFile.GetContent()
 	log.Printf("配置文件内容:\n%s", content)
 	log.Printf("配置文件内容长度: %d 字符", len(content))
+	log.Printf("fetched config file:\n %s\n", getString(configFile))
 
 	// 方式一：添加监听器
 	log.Println("添加配置变更监听器（回调函数方式）...")
@@ -67,6 +86,7 @@ func main() {
 		select {
 		case event := <-changeChan:
 			log.Printf("通过通道接收到配置变更事件: %+v", event)
+			log.Printf("updated config file:\n %s\n", getString(configFile))
 		}
 	}
 }
@@ -89,3 +109,18 @@ func jsonMarshal(v interface{}) string {
 	}
 	return string(data)
 }
+
+func getString(c model.ConfigFile) string {
+	return fmt.Sprintf("ConfigFile{Namespace=%s, FileGroup=%s, FileName=%s, Version=%d, VersionName=%s, Md5=%s, "+
+		"Labels=%v, HasContent=%t, ContentLength=%d}",
+		c.GetNamespace(),
+		c.GetFileGroup(),
+		c.GetFileName(),
+		c.GetVersion(),
+		c.GetVersionName(),
+		c.GetMd5(),
+		c.GetLabels(),
+		c.HasContent(),
+		len(c.GetContent()),
+	)
+}

pkg/flow/configuration/model.go

@@ -73,6 +73,30 @@ func (c *defaultConfigFile) GetPersistent() model.Persistent {
 	return c.persistent
 }
 
+// GetVersionName 获取配置文件版本名称
+func (c *defaultConfigFile) GetVersionName() string {
+	if c.fileRepo == nil || c.fileRepo.loadRemoteFile() == nil {
+		return ""
+	}
+	return c.fileRepo.loadRemoteFile().GetVersionName()
+}
+
+// GetVersion 获取配置文件版本号
+func (c *defaultConfigFile) GetVersion() uint64 {
+	if c.fileRepo == nil || c.fileRepo.loadRemoteFile() == nil {
+		return 0
+	}
+	return c.fileRepo.loadRemoteFile().GetVersion()
+}
+
+// GetMd5 获取配置文件MD5值
+func (c *defaultConfigFile) GetMd5() string {
+	if c.fileRepo == nil || c.fileRepo.loadRemoteFile() == nil {
+		return ""
+	}
+	return c.fileRepo.loadRemoteFile().GetMd5()
+}
+
 // HasContent 是否有配置内容
 func (c *defaultConfigFile) HasContent() bool {
 	return c.content != "" && c.content != NotExistedFileContent

pkg/model/config.go

@@ -117,6 +117,12 @@ type ConfigFile interface {
 	AddChangeListener(cb OnConfigFileChange)
 	// GetPersistent 获取文件持久化数据
 	GetPersistent() Persistent
+	// GetVersionName 获取配置文件版本名称
+	GetVersionName() string
+	// GetVersion 获取配置文件版本
+	GetVersion() uint64
+	// GetMd5 获取配置文件md5值
+	GetMd5() string
 }
 
 // DefaultConfigFileMetadata 默认 ConfigFileMetadata 实现类