feat: support config event and monitor address list.

Author: fishtailfu

polaris-plugins/polaris-plugins-observability/event-pushgateway/src/main/java/com/tencent/polaris/plugins/event/pushgateway/PushGatewayEventReporter.java

@@ -152,7 +152,7 @@ public void postContextInit(Extensions ctx) throws PolarisException {
 
                         eventQueue = new LinkedBlockingQueue<>(config.getEventQueueSize());
 
-                        serviceAddressRepository = new ServiceAddressRepository(Collections.singletonList(this.config.getAddress()),
+                        serviceAddressRepository = new ServiceAddressRepository(this.config.getAddress(),
                                 ctx.getValueContext().getClientId(), ctx, new ServiceKey(config.getNamespace(), config.getService()));
 
                         eventExecutors.scheduleWithFixedDelay(new PushGatewayEventTask(), 1000, 1000, TimeUnit.MILLISECONDS);

polaris-plugins/polaris-plugins-observability/event-pushgateway/src/main/java/com/tencent/polaris/plugins/event/pushgateway/PushGatewayEventReporterConfig.java

@@ -19,8 +19,10 @@
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.tencent.polaris.api.config.verify.Verifier;
+import com.tencent.polaris.api.utils.CollectionUtils;
 import com.tencent.polaris.api.utils.StringUtils;
 import com.tencent.polaris.factory.util.ConfigUtils;
+import java.util.List;
 
 /**
  * Polaris push gateway event reporter config.
@@ -32,8 +34,9 @@ public class PushGatewayEventReporterConfig implements Verifier {
     @JsonProperty
     private Boolean enable;
 
+
     @JsonProperty
-    private String address;
+    private List<String> address;
 
     @JsonProperty
     private Integer eventQueueSize;
@@ -53,7 +56,6 @@ public void verify() {
         if (!enable) {
             return;
         }
-        ConfigUtils.validateString(address, "global.eventReporter.plugin.pushgateway.address");
         ConfigUtils.validatePositive(eventQueueSize, "global.eventReporter.plugin.pushgateway.eventQueueSize");
         ConfigUtils.validatePositive(maxBatchSize, "global.eventReporter.plugin.pushgateway.maxBatchSize");
         ConfigUtils.validateString(namespace, "global.eventReporter.plugin.pushgateway.namespace");
@@ -67,7 +69,7 @@ public void setDefault(Object defaultObject) {
             if (null == enable) {
                 setEnable(pushGatewayEventReporterConfig.isEnable());
             }
-            if (StringUtils.isBlank(address)) {
+            if (CollectionUtils.isEmpty(address)) {
                 setAddress(pushGatewayEventReporterConfig.getAddress());
             }
             if (null == eventQueueSize) {
@@ -96,11 +98,11 @@ public void setEnable(boolean enable) {
         this.enable = enable;
     }
 
-    public String getAddress() {
+    public List<String> getAddress() {
         return address;
     }
 
-    public void setAddress(String address) {
+    public void setAddress(List<String> address) {
         this.address = address;
     }
 

polaris-plugins/polaris-plugins-observability/stat-prometheus/src/main/java/com/tencent/polaris/plugins/stat/prometheus/handler/PrometheusHandlerConfig.java

@@ -20,10 +20,12 @@
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import com.tencent.polaris.api.config.verify.Verifier;
+import com.tencent.polaris.api.utils.CollectionUtils;
 import com.tencent.polaris.api.utils.StringUtils;
 import com.tencent.polaris.factory.util.TimeStrJsonDeserializer;
 
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 
 /**
@@ -38,8 +40,7 @@ public class PrometheusHandlerConfig implements Verifier {
     private String type;
 
     @JsonProperty
-    private String address;
-
+    private List<String> address;
     @JsonProperty
     private String namespace;
 
@@ -82,7 +83,7 @@ public void setDefault(Object defaultObject) {
             if (StringUtils.isBlank(path)) {
                 setPath(config.getPath());
             }
-            if (StringUtils.isBlank(address)) {
+            if (CollectionUtils.isEmpty(address)) {
                 setAddress(config.getAddress());
             }
             if (null == pushInterval) {
@@ -116,11 +117,11 @@ public void setPath(String path) {
         this.path = path;
     }
 
-    public String getAddress() {
+    public List<String> getAddress() {
         return address;
     }
 
-    public void setAddress(String address) {
+    public void setAddress(List<String> address) {
         this.address = address;
     }
 

polaris-plugins/polaris-plugins-observability/stat-prometheus/src/main/java/com/tencent/polaris/plugins/stat/prometheus/plugin/PrometheusReporter.java

@@ -129,7 +129,7 @@ public void postContextInit(Extensions extensions) throws PolarisException {
         this.executorService = Executors.newScheduledThreadPool(4, new NamedThreadFactory(getName()));
         this.port = extensions.getConfiguration().getGlobal().getAdmin().getPort();
 
-        this.serviceAddressRepository = new ServiceAddressRepository(Collections.singletonList(this.config.getAddress()),
+        this.serviceAddressRepository = new ServiceAddressRepository(this.config.getAddress(),
                 extensions.getValueContext().getClientId(), extensions, new ServiceKey(config.getNamespace(), config.getService()));
 
         if (CollectionUtils.isNotEmpty(config.getPathRegexList())) {