feat: support config event

Author: shedfreez

polaris-common/polaris-client/src/main/java/com/tencent/polaris/client/flow/BaseFlow.java

@@ -27,6 +27,7 @@
 import com.tencent.polaris.api.plugin.compose.DefaultRouterChainGroup;
 import com.tencent.polaris.api.plugin.compose.Extensions;
 import com.tencent.polaris.api.plugin.compose.RouterChainGroup;
+import com.tencent.polaris.api.plugin.event.ConfigEvent;
 import com.tencent.polaris.api.plugin.event.EventReporter;
 import com.tencent.polaris.api.plugin.event.FlowEvent;
 import com.tencent.polaris.api.plugin.loadbalance.LoadBalancer;
@@ -368,4 +369,23 @@ public static void reportFlowEvent(Extensions extensions, FlowEvent flowEvent) {
             }
         }
     }
+
+    public static void reportConfigEvent(Extensions extensions, ConfigEvent flowEvent) {
+        List<EventReporter> eventReporterList = extensions.getEventReporterList();
+        if (LOG.isDebugEnabled()) {
+            LOG.debug("Reporting config event: {}", flowEvent);
+        }
+        for (EventReporter eventReporter : eventReporterList) {
+            try {
+                if (!eventReporter.isEnabled()) {
+                    continue;
+                }
+                if (!eventReporter.reportEvent(flowEvent)) {
+                    LOG.warn("Report event by {} failed. Config event detail: {}", eventReporter.getName(), flowEvent);
+                }
+            } catch (Throwable throwable) {
+                LOG.warn("Report event by {} failed. Config event detail: {}", eventReporter.getName(), flowEvent, throwable);
+            }
+        }
+    }
 }

polaris-common/polaris-model/src/main/java/com/tencent/polaris/api/pojo/ServiceEventKey.java

@@ -52,6 +52,7 @@ public enum EventType {
         NEARBY_ROUTE_RULE,
         LOSSLESS,
         BLOCK_ALLOW_RULE,
+        CONFIG_UPDATED,
     }
 
     private final ServiceKey serviceKey;

polaris-configuration/polaris-configuration-api/pom.xml

@@ -20,5 +20,12 @@
             <artifactId>polaris-client</artifactId>
             <version>${project.version}</version>
         </dependency>
+
+        <dependency>
+            <groupId>com.tencent.polaris</groupId>
+            <artifactId>polaris-plugin-api</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
     </dependencies>
 </project>

polaris-configuration/polaris-configuration-api/src/main/java/com/tencent/polaris/configuration/api/core/ConfigFileMetadata.java

@@ -29,4 +29,6 @@ public interface ConfigFileMetadata {
     String getFileGroup();
 
     String getFileName();
+
+    String getFileVersion();
 }

polaris-configuration/polaris-configuration-api/src/main/java/com/tencent/polaris/configuration/api/core/ConfigKVFileChangeEvent.java

@@ -20,15 +20,20 @@
 import java.util.Map;
 import java.util.Set;
 
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
+
 /**
  * @author lepdou 2022-03-01
  */
 public class ConfigKVFileChangeEvent {
 
     private final Map<String, ConfigPropertyChangeInfo> propertyChangeInfos;
 
-    public ConfigKVFileChangeEvent(Map<String, ConfigPropertyChangeInfo> changeInfos) {
+    private final com.tencent.polaris.api.plugin.configuration.ConfigFile configFile;
+
+    public ConfigKVFileChangeEvent(Map<String, ConfigPropertyChangeInfo> changeInfos, com.tencent.polaris.api.plugin.configuration.ConfigFile configFile) {
         this.propertyChangeInfos = changeInfos;
+        this.configFile = configFile;
     }
 
     public Set<String> changedKeys() {
@@ -67,4 +72,7 @@ public ChangeType getPropertiesChangeType(String propertyKey) {
         return ChangeType.NOT_CHANGED;
     }
 
+    public ConfigFile getConfigFile() {
+        return configFile;
+    }
 }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/AbstractConfigFileRepo.java

@@ -18,6 +18,7 @@
 package com.tencent.polaris.configuration.client.internal;
 
 import com.google.common.collect.Lists;
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
 import com.tencent.polaris.client.api.SDKContext;
 import com.tencent.polaris.configuration.api.core.ConfigFileMetadata;
 import com.tencent.polaris.logging.LoggerFactory;
@@ -65,10 +66,10 @@ public void removeChangeListener(ConfigFileRepoChangeListener listener) {
         listeners.remove(listener);
     }
 
-    protected void fireChangeEvent(String newContent) {
+    protected void fireChangeEvent(ConfigFile configFile) {
         for (ConfigFileRepoChangeListener listener : listeners) {
             try {
-                listener.onChange(configFileMetadata, newContent);
+                listener.onChange(configFileMetadata, configFile);
             } catch (Throwable t) {
                 LOGGER.error("[Config] invoke config file repo change listener failed. config file = {}, listener = {}",
                         configFileMetadata, listener.getClass(), t);

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/CompositeConfigFile.java

@@ -193,4 +193,9 @@ public String getFileGroup() {
     public String getFileName() {
         return "";
     }
+
+    @Override
+    public String getFileVersion() {
+        return "";
+    }
 }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/ConfigFileRepoChangeListener.java

@@ -17,13 +17,14 @@
 
 package com.tencent.polaris.configuration.client.internal;
 
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
 import com.tencent.polaris.configuration.api.core.ConfigFileMetadata;
 
 /**
  * @author lepdou 2022-03-02
  */
 public interface ConfigFileRepoChangeListener {
 
-    void onChange(ConfigFileMetadata configFileMetadata, String newContent);
+    void onChange(ConfigFileMetadata configFileMetadata, ConfigFile configFile);
 
 }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/ConfigPropertiesFile.java

@@ -23,6 +23,7 @@
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.tencent.polaris.api.config.configuration.ConfigFileConfig;
+import com.tencent.polaris.api.plugin.configuration.ConfigFile;
 import com.tencent.polaris.configuration.api.core.*;
 import com.tencent.polaris.configuration.client.util.ConfigFileUtils;
 import com.tencent.polaris.configuration.client.util.ConvertFunctions;
@@ -321,9 +322,9 @@ public void removeChangeListener(ConfigKVFileChangeListener listener) {
     }
 
     @Override
-    public void onChange(ConfigFileMetadata configFileMetadata, String newContent) {
-        super.onChange(configFileMetadata, newContent);
-
+    public void onChange(ConfigFileMetadata configFileMetadata, ConfigFile configFile) {
+        super.onChange(configFileMetadata, configFile);
+        String newContent = Optional.ofNullable(configFile).map(ConfigFile::getContent).orElse(null);
         Properties oldProperties = this.properties.get();
         if (oldProperties == null) {
             oldProperties = new Properties();
@@ -358,7 +359,7 @@ public void onChange(ConfigFileMetadata configFileMetadata, String newContent) {
 
         clearConfigCache();
 
-        ConfigKVFileChangeEvent event = new ConfigKVFileChangeEvent(changeInfos);
+        ConfigKVFileChangeEvent event = new ConfigKVFileChangeEvent(changeInfos, configFile);
 
         fireChangeEvent(event);
     }

polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/DefaultConfigFile.java

@@ -33,6 +33,7 @@
 import java.lang.reflect.Type;
 import java.util.List;
 import java.util.Objects;
+import java.util.Optional;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
@@ -170,8 +171,9 @@ public void removeChangeListener(ConfigFileChangeListener listener) {
     }
 
     @Override
-    public void onChange(ConfigFileMetadata configFileMetadata, String newContent) {
+    public void onChange(ConfigFileMetadata configFileMetadata, com.tencent.polaris.api.plugin.configuration.ConfigFile configFile) {
         String oldContent = this.content;
+        String newContent = Optional.ofNullable(configFile).map(com.tencent.polaris.api.plugin.configuration.ConfigFile::getContent).orElse(null);
         this.content = newContent;
 
         ChangeType changeType = ChangeType.MODIFIED;