feat:配置文件支持获取标签信息

api.go

@@ -131,14 +131,19 @@ func NewQuotaRequest() QuotaRequest {
 	return &model.QuotaRequestImpl{}
 }
 
+type GetConfigFileRequest api.GetConfigFileRequest
+
 // ConfigFile config
 type ConfigFile model.ConfigFile
 
 // ConfigAPI api for configuration files.
 type ConfigAPI interface {
 	api.SDKOwner
-	// GetConfigFile obtaining the configuration file
-	GetConfigFile(namespace, fileGroup, fileName string) (ConfigFile, error)
+	// Deprecated: please use FetchConfigFile
+	// GetConfigFile 获取配置文件
+	GetConfigFile(namespace, fileGroup, fileName string) (model.ConfigFile, error)
+	// FetchConfigFile 获取配置文件
+	FetchConfigFile(*GetConfigFileRequest) (model.ConfigFile, error)
 	// CreateConfigFile create configuration file
 	CreateConfigFile(namespace, fileGroup, fileName, content string) error
 	// UpdateConfigFile update configuration file

api_config.go

@@ -69,10 +69,15 @@ func NewConfigAPIByContext(context api.SDKContext) ConfigAPI {
 }
 
 // GetConfigFile 获取配置文件
-func (c *configAPI) GetConfigFile(namespace, fileGroup, fileName string) (ConfigFile, error) {
+func (c *configAPI) GetConfigFile(namespace, fileGroup, fileName string) (model.ConfigFile, error) {
 	return c.rawAPI.GetConfigFile(namespace, fileGroup, fileName)
 }
 
+// FetchConfigFile .
+func (c *configAPI) FetchConfigFile(req *GetConfigFileRequest) (model.ConfigFile, error) {
+	return c.rawAPI.FetchConfigFile((*api.GetConfigFileRequest)(req))
+}
+
 // CreateConfigFile 创建配置文件
 func (c *configAPI) CreateConfigFile(namespace, fileGroup, fileName, content string) error {
 	return c.rawAPI.CreateConfigFile(namespace, fileGroup, fileName, content)

pkg/flow/configuration/model.go

@@ -49,6 +49,15 @@ func newDefaultConfigFile(metadata model.ConfigFileMetadata, repo *ConfigFileRep
 	return configFile
 }
 
+// GetLabels 获取标签
+func (c *defaultConfigFile) GetLabels() map[string]string {
+	remote := c.fileRepo.loadRemoteFile()
+	if remote == nil {
+		return map[string]string{}
+	}
+	return remote.GetLabels()
+}
+
 // GetContent 获取配置文件内容
 func (c *defaultConfigFile) GetContent() string {
 	if c.content == NotExistedFileContent {

pkg/model/config.go

@@ -79,6 +79,8 @@ type ConfigFileMetadata interface {
 // ConfigFile 文本类型配置文件对象
 type ConfigFile interface {
 	ConfigFileMetadata
+	// GetLabels 获取配置文件标签
+	GetLabels() map[string]string
 	// GetContent 获取配置文件内容
 	GetContent() string
 	// HasContent 是否有配置内容

pkg/plugin/configconnector/config_file.go

@@ -73,6 +73,14 @@ type ConfigFileTag struct {
 	Value string
 }
 
+func (c *ConfigFile) GetLabels() map[string]string {
+	ret := make(map[string]string, len(c.Tags))
+	for i := range c.Tags {
+		ret[c.Tags[i].Key] = c.Tags[i].Value
+	}
+	return ret
+}
+
 // GetNamespace 获取配置文件命名空间
 func (c *ConfigFile) GetNamespace() string {
 	return c.Namespace