Multi datacenter

.github/workflows/integration-test.yml

@@ -20,13 +20,7 @@ jobs:
         uses: actions/setup-java@v1
         with:
           java-version: 1.8
-      - name: Integration Test
+      - name: ut
         run: mvn compile -B
-          && mvn clean test -DisSkipUnitTest=true "-Dtest.logging.level=ERROR"
-      - name: Publish Test Report
-        if: ${{ always() }}
-        uses: ScaCap/action-surefire-report@v1
-        with:
-          fail_on_test_failures: true
-          skip_publishing: true
-
+          && sh ./tools/check_format.sh
+          && mvn clean test -DisSkipUnitTest=true "-Dtest.logging.level=ERROR"

.github/workflows/unit-test.yml

@@ -15,22 +15,16 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
-      - uses: actions/checkout@v2
-      - name: Set up JDK 1.8
-        uses: actions/setup-java@v1
-        with:
-          java-version: 1.8
-      - name: Unit Testt
-        run: mvn compile -B
-          && mvn clean test -DisSkipIntegrationTest=true "-Dtest.logging.level=ERROR" --fail-at-end --batch-mode
-      - name: Publish Test Report
-        if: ${{ always() }}
-        uses: ScaCap/action-surefire-report@v1
-        with:
-          fail_on_test_failures: true
-          skip_publishing: true
-      - name: Codecov
-        uses: codecov/codecov-action@v1
-        with:
-          token: ${{secrets.CODECOV_TOKEN}}
-          fail_ci_if_error: false
+    - uses: actions/checkout@v2
+    - name: Set up JDK 1.8
+      uses: actions/setup-java@v1
+      with:
+        java-version: 1.8
+    - name: ut
+      run: mvn compile -B
+        && sh ./tools/check_format.sh
+        && mvn clean test -DisSkipIntegrationTest=true "-Dtest.logging.level=ERROR"
+    - name: Codecov
+      uses: codecov/codecov-action@v1
+      with:
+        token: ${{secrets.CODECOV_TOKEN}}

README.md

@@ -34,16 +34,8 @@ SOFARegistry 是蚂蚁金服开源的一个生产级、高时效、高可用的
 - [运维手册](https://www.sofastack.tech/sofa-registry/docs/Deployment)
 - [发布历史](https://www.sofastack.tech/sofa-registry/docs/ReleaseNotes)
 - [发展路线](https://www.sofastack.tech/sofa-registry/docs/RoadMap)
-- 源码解析
-   - [发布订阅推送](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-publish-subscription-push/)
-   - [registry meta 选主](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-registry-meta/)
-   - [SlotTable](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-slottable/)
-   - [数据倒排索引](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-data-inverted-index/)
-   - [数据表监听](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyza-data-table-listening/)
-   - [无损运维](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-non-destructive-o-and-m/)
-   - [推送延迟 trace](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-push-delay-trace/)
-   - [推送开关](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-push-switch/)
-   - [通讯数据压缩](https://www.sofastack.tech/projects/sofa-registry/code-analyze/code-analyze-communication-data-compression/)
+
+
 ## 贡献
 
 [如何参与 SOFARegistry 代码贡献](https://www.sofastack.tech/sofa-registry/docs/Contributing)

VERSION

@@ -1 +1 @@
-6.1.9
+6.2.1-SNAPSHOT

client/all/pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.alipay.sofa</groupId>
     <artifactId>registry-client-all</artifactId>
-    <version>6.1.9</version>
+    <version>6.2.1-SNAPSHOT</version>
 
     <name>${project.groupId}:${project.artifactId}</name>
     <url>http://github.com/alipay/sofa-registry</url>

client/api/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <groupId>com.alipay.sofa</groupId>
         <artifactId>registry-client-parent</artifactId>
-        <version>6.1.9</version>
+        <version>6.2.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

client/impl/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <groupId>com.alipay.sofa</groupId>
         <artifactId>registry-client-parent</artifactId>
-        <version>6.1.9</version>
+        <version>6.2.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

client/log/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <groupId>com.alipay.sofa</groupId>
         <artifactId>registry-client-parent</artifactId>
-        <version>6.1.9</version>
+        <version>6.2.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

client/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>com.alipay.sofa</groupId>
         <artifactId>registry-parent</artifactId>
-        <version>6.1.9</version>
+        <version>6.2.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

codecov.yml

@@ -11,4 +11,4 @@ ignore:
 comment:
   behavior: default
   layout: reach,diff,flags,files,footer
-  require_changes: false
+  require_changes: false

core/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <groupId>com.alipay.sofa</groupId>
         <artifactId>registry-parent</artifactId>
-        <version>6.1.9</version>
+        <version>6.2.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

core/src/main/java/com/alipay/sofa/registry/core/model/MultiReceivedData.java

@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alipay.sofa.registry.core.model;
+
+import java.io.Serializable;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author xiaojian.xj
+ * @version : MultiReceivedData.java, v 0.1 2022年07月17日 16:18 xiaojian.xj Exp $
+ */
+public class MultiReceivedData implements Serializable {
+
+  private static final long serialVersionUID = -1741750169930120188L;
+
+  private String dataId;
+
+  private String group;
+
+  private String instanceId;
+
+  private String scope;
+
+  private List<String /*registId*/> subscriberRegistIds;
+
+  private String localSegment;
+
+  private String localZone;
+
+  private Map<String, MultiSegmentData> multiData;
+
+  public MultiReceivedData() {}
+
+  /**
+   * Getter method for property <tt>dataId</tt>.
+   *
+   * @return property value of dataId
+   */
+  public String getDataId() {
+    return dataId;
+  }
+
+  /**
+   * Setter method for property <tt>dataId</tt>.
+   *
+   * @param dataId value to be assigned to property dataId
+   */
+  public void setDataId(String dataId) {
+    this.dataId = dataId;
+  }
+
+  /**
+   * Getter method for property <tt>group</tt>.
+   *
+   * @return property value of group
+   */
+  public String getGroup() {
+    return group;
+  }
+
+  /**
+   * Setter method for property <tt>group</tt>.
+   *
+   * @param group value to be assigned to property group
+   */
+  public void setGroup(String group) {
+    this.group = group;
+  }
+
+  /**
+   * Getter method for property <tt>instanceId</tt>.
+   *
+   * @return property value of instanceId
+   */
+  public String getInstanceId() {
+    return instanceId;
+  }
+
+  /**
+   * Setter method for property <tt>instanceId</tt>.
+   *
+   * @param instanceId value to be assigned to property instanceId
+   */
+  public void setInstanceId(String instanceId) {
+    this.instanceId = instanceId;
+  }
+
+  /**
+   * Getter method for property <tt>scope</tt>.
+   *
+   * @return property value of scope
+   */
+  public String getScope() {
+    return scope;
+  }
+
+  /**
+   * Setter method for property <tt>scope</tt>.
+   *
+   * @param scope value to be assigned to property scope
+   */
+  public void setScope(String scope) {
+    this.scope = scope;
+  }
+
+  /**
+   * Getter method for property <tt>subscriberRegistIds</tt>.
+   *
+   * @return property value of subscriberRegistIds
+   */
+  public List<String> getSubscriberRegistIds() {
+    return subscriberRegistIds;
+  }
+
+  /**
+   * Setter method for property <tt>subscriberRegistIds</tt>.
+   *
+   * @param subscriberRegistIds value to be assigned to property subscriberRegistIds
+   */
+  public void setSubscriberRegistIds(List<String> subscriberRegistIds) {
+    this.subscriberRegistIds = subscriberRegistIds;
+  }
+
+  /**
+   * Getter method for property <tt>localSegment</tt>.
+   *
+   * @return property value of localSegment
+   */
+  public String getLocalSegment() {
+    return localSegment;
+  }
+
+  /**
+   * Setter method for property <tt>localSegment</tt>.
+   *
+   * @param localSegment value to be assigned to property localSegment
+   */
+  public void setLocalSegment(String localSegment) {
+    this.localSegment = localSegment;
+  }
+
+  /**
+   * Getter method for property <tt>localZone</tt>.
+   *
+   * @return property value of localZone
+   */
+  public String getLocalZone() {
+    return localZone;
+  }
+
+  /**
+   * Setter method for property <tt>localZone</tt>.
+   *
+   * @param localZone value to be assigned to property localZone
+   */
+  public void setLocalZone(String localZone) {
+    this.localZone = localZone;
+  }
+
+  /**
+   * Getter method for property <tt>multiData</tt>.
+   *
+   * @return property value of multiData
+   */
+  public Map<String, MultiSegmentData> getMultiData() {
+    return multiData;
+  }
+
+  /**
+   * Setter method for property <tt>multiData</tt>.
+   *
+   * @param multiData value to be assigned to property multiData
+   */
+  public void setMultiData(Map<String, MultiSegmentData> multiData) {
+    this.multiData = multiData;
+  }
+
+  @Override
+  public String toString() {
+    return "MultiReceivedData{"
+        + "dataId='"
+        + dataId
+        + '\''
+        + ", group='"
+        + group
+        + '\''
+        + ", instanceId='"
+        + instanceId
+        + '\''
+        + ", scope='"
+        + scope
+        + '\''
+        + ", subscriberRegistIds="
+        + subscriberRegistIds
+        + ", localSegment='"
+        + localSegment
+        + '\''
+        + ", localZone='"
+        + localZone
+        + '\''
+        + ", multiData="
+        + multiData
+        + '}';
+  }
+}