Skip to content

Commit dee9180

Browse files
authored
feat(config): 发布配置元数据时增加日志记录和通知 (#13999)
- 在 ConfigControllerV3 中添加了日志记录和配置变更通知 - 在 ConfigTraceService 中增加了 PERSISTENCE_EVENT_METADATA 常量 Change-Id: I9011724d2c39570f00d3ddbf433f5d9cf4723786
1 parent b1ab8fb commit dee9180

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

config/src/main/java/com/alibaba/nacos/config/server/controller/v3/ConfigControllerV3.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ public class ConfigControllerV3 {
138138
private final ConfigListenerStateDelegate configListenerStateDelegate;
139139

140140
private final ConfigMigrateService configMigrateService;
141-
141+
142142
/**
143143
* Flag to indicate if the table `config_info_beta` exists, which means the old version of table schema is used.
144144
*/
@@ -244,13 +244,18 @@ public Result<Boolean> publishConfig(HttpServletRequest request, ConfigFormV3 co
244244
public Result<Boolean> publishConfigMetadata(HttpServletRequest request, ConfigFormV3 configForm)
245245
throws NacosException {
246246
configForm.validate();
247+
String remoteIp = getRemoteIp(request);
247248
String configTags = configForm.getConfigTags();
248249
String description = configForm.getDesc();
249250
String dataId = configForm.getDataId();
250251
String group = configForm.getGroup();
251252
String namespaceId = NamespaceUtil.processNamespaceParameter(configForm.getNamespaceId());
252253
configInfoPersistService.updateConfigInfoMetadata(dataId, group, namespaceId, configTags, description);
253254
configMigrateService.updateConfigMetadataMigrate(dataId, group, namespaceId, configTags, description);
255+
final Timestamp time = TimeUtils.getCurrentTime();
256+
ConfigTraceService.logPersistenceEvent(dataId, group, namespaceId, null, time.getTime(), remoteIp,
257+
ConfigTraceService.PERSISTENCE_EVENT_METADATA, ConfigTraceService.PERSISTENCE_TYPE_PUB, null);
258+
ConfigChangePublisher.notifyConfigChange(new ConfigDataChangeEvent(dataId, group, namespaceId, time.getTime()));
254259
return Result.success(true);
255260
}
256261

config/src/main/java/com/alibaba/nacos/config/server/service/trace/ConfigTraceService.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,8 @@ public class ConfigTraceService {
4343

4444
public static final String PERSISTENCE_EVENT_TAG = "persist-tag";
4545

46+
public static final String PERSISTENCE_EVENT_METADATA = "persist-metadata";
47+
4648
/**
4749
* persist type.
4850
*/

0 commit comments

Comments
 (0)