You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by du...@apache.org on 2022/01/14 06:49:19 UTC

[shardingsphere] branch master updated (4747d3a -> 2bc2051)

This is an automated email from the ASF dual-hosted git repository.

duanzhengqiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.


    from 4747d3a  Separate RuleAlteredJobAPI from PipelineJobAPI; Simplify SPI loading (#14759)
     add 2bc2051  add worker id generator for cluster mode (#14763)

No new revisions were added by this update.

Summary of changes:
 .../collector/ProxyInfoCollectorTest.java          |  4 ++-
 .../service/PrometheusPluginBootServiceTest.java   |  4 ++-
 .../infra/instance/InstanceContext.java            | 20 ++++++++++++++-
 .../infra/instance/workerid/WorkerIdGenerator.java | 12 ++++-----
 .../repository/TestClusterPersistRepository.java   |  5 ++++
 .../cluster/ClusterContextManagerBuilder.java      |  4 ++-
 .../generator/ClusterWorkerIdGenerator.java}       | 29 ++++++++++++++--------
 .../registry/workerid/node/WorkerIdNode.java       | 19 ++++++++++++++
 .../fixture/ClusterPersistRepositoryFixture.java   |  5 ++++
 ...ProcessListClusterPersistRepositoryFixture.java |  5 ++++
 .../cluster/ClusterPersistRepository.java          |  9 +++++++
 .../repository/cluster/etcd/EtcdRepository.java    |  7 +++++-
 .../zookeeper/CuratorZookeeperRepository.java      | 13 ++++++++++
 .../memory/MemoryContextManagerBuilder.java        |  3 ++-
 .../generator/MemoryWorkerIdGenerator.java         | 10 ++++----
 .../StandaloneContextManagerBuilder.java           |  4 ++-
 .../generator/StandaloneWorkerIdGenerator.java     | 11 ++++----
 .../fixture/FixtureClusterPersistRepository.java   |  5 ++++
 .../fixture/TestClusterPersistRepository.java      |  5 ++++
 19 files changed, 140 insertions(+), 34 deletions(-)
 copy shardingsphere-agent/shardingsphere-agent-api/src/main/java/org/apache/shardingsphere/agent/spi/type/AgentTypedSPI.java => shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/instance/workerid/WorkerIdGenerator.java (81%)
 copy shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/{status/compute/service/ComputeNodeStatusService.java => workerid/generator/ClusterWorkerIdGenerator.java} (51%)
 create mode 100644 shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/workerid/node/WorkerIdNode.java
 copy shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/dml/EmptyStatement.java => shardingsphere-mode/shardingsphere-mode-type/shardingsphere-memory-mode/shardingsphere-memory-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/memory/workerid/generator/MemoryWorkerIdGenerator.java (74%)
 copy shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/dml/EmptyStatement.java => shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/workerid/generator/StandaloneWorkerIdGenerator.java (72%)