This is an automated email from the ASF dual-hosted git repository.
menghaoran pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from e851ca6 Add DialectSystemSchemaBuilder interface and implement system
schema logic (#16272)
add d722336 Add basic framework for global lock by cluster mode (#16270)
No new revisions were added by this update.
Summary of changes:
.../collector/ProxyInfoCollectorTest.java | 5 +-
.../service/PrometheusPluginBootServiceTest.java | 5 +-
.../infra/lock/ShardingSphereGlobalLock.java | 26 +--
.../shardingsphere/mode/lock/LockContext.java | 30 +++-
.../mode/manager/ContextManager.java | 7 +-
.../mode/manager/ContextManagerTest.java | 3 +-
.../cluster/ClusterContextManagerBuilder.java | 6 +-
.../future/lock/DistributeLockContext.java | 180 ++++++++++++++++++++
.../lock/ShardingSphereDistributeGlobalLock.java | 186 +++++++++++++++++++++
.../lock/event/AckLockReleasedEvent.java} | 10 +-
.../lock/event/AckLockedEvent.java} | 10 +-
.../{ => future}/lock/event/LockReleasedEvent.java | 6 +-
.../lock/event/LockedEvent.java} | 10 +-
.../lock/service/GlobalLockRegistryService.java | 73 ++++++++
.../future/lock/util/GlobalLockNode.java | 112 +++++++++++++
.../lock/watcher/GlobalAckChangedWatcher.java} | 42 +++--
.../lock/watcher/GlobalLocksChangedWatcher.java} | 41 +++--
....cluster.coordinator.registry.GovernanceWatcher | 2 +
.../lock/util/GlobalLockNodeTest.java} | 29 ++--
.../memory/MemoryContextManagerBuilder.java | 3 +-
.../manager/memory/lock/MemoryLockContext.java | 23 +--
.../StandaloneContextManagerBuilder.java | 3 +-
.../standalone/lock/StandaloneLockContext.java | 23 +--
.../pipeline/core/util/PipelineContextUtil.java | 2 +-
24 files changed, 719 insertions(+), 118 deletions(-)
copy
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobAPI.java
=>
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/lock/ShardingSphereGlobalLock.java
(61%)
copy
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/spi/lock/JobLock.java
=>
shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/lock/LockContext.java
(60%)
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/future/lock/DistributeLockContext.java
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/future/lock/ShardingSphereDistributeGlobalLock.java
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/event/WorkerIdEvent.java
=> future/lock/event/AckLockReleasedEvent.java} (84%)
copy
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/{registry/metadata/event/SchemaDeletedEvent.java
=> future/lock/event/AckLockedEvent.java} (85%)
copy
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/{
=> future}/lock/event/LockReleasedEvent.java (91%)
copy
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/{registry/metadata/event/SchemaDeletedEvent.java
=> future/lock/event/LockedEvent.java} (85%)
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/future/lock/service/GlobalLockRegistryService.java
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/future/lock/util/GlobalLockNode.java
copy
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/{lock/watcher/LockChangedWatcher.java
=> future/lock/watcher/GlobalAckChangedWatcher.java} (56%)
copy
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/{lock/watcher/LockChangedWatcher.java
=> future/lock/watcher/GlobalLocksChangedWatcher.java} (57%)
copy
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/{lock/service/LockNodeTest.java
=> future/lock/util/GlobalLockNodeTest.java} (60%)
copy
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/datasource/pool/destroyer/detector/type/DefaultDataSourcePoolActiveDetector.java
=>
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-memory-mode/shardingsphere-memory-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/memory/lock/MemoryLockContext.java
(60%)
copy
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/datasource/pool/destroyer/detector/type/DefaultDataSourcePoolActiveDetector.java
=>
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/lock/StandaloneLockContext.java
(59%)
