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%)