You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2021/02/04 10:43:16 UTC
[shardingsphere] branch master updated: Rename
SchemasChangedListener to MetaDataChangedListener (#9324)
This is an automated email from the ASF dual-hosted git repository.
zhangyonglun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 141a3a5 Rename SchemasChangedListener to MetaDataChangedListener (#9324)
141a3a5 is described below
commit 141a3a5bfd1b995192ad923e428ee47d1dae47c9
Author: Haoran Meng <me...@gmail.com>
AuthorDate: Thu Feb 4 18:42:55 2021 +0800
Rename SchemasChangedListener to MetaDataChangedListener (#9324)
---
.../{SchemasChangedListener.java => MetaDataChangedListener.java} | 4 ++--
.../governance/core/config/listener/metadata/MetaDataListener.java | 6 +++---
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/SchemasChangedListener.java b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataChangedListener.java
similarity index 93%
rename from shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/SchemasChangedListener.java
rename to shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataChangedListener.java
index 0e461de..fe56c17 100644
--- a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/SchemasChangedListener.java
+++ b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataChangedListener.java
@@ -36,13 +36,13 @@ import java.util.Set;
/**
* Schemas changed listener.
*/
-public final class SchemasChangedListener extends PostGovernanceRepositoryEventListener<GovernanceEvent> {
+public final class MetaDataChangedListener extends PostGovernanceRepositoryEventListener<GovernanceEvent> {
private final Collection<String> existedSchemaNames;
private final ConfigCenterNode configurationNode;
- public SchemasChangedListener(final ConfigurationRepository configurationRepository, final Collection<String> schemaNames) {
+ public MetaDataChangedListener(final ConfigurationRepository configurationRepository, final Collection<String> schemaNames) {
super(configurationRepository, Collections.singleton(new ConfigCenterNode().getMetadataNodePath()));
configurationNode = new ConfigCenterNode();
existedSchemaNames = new LinkedHashSet<>(schemaNames);
diff --git a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java
index 1eaf6e1..b28212b 100644
--- a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java
+++ b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/metadata/MetaDataListener.java
@@ -30,7 +30,7 @@ import java.util.Collection;
*/
public final class MetaDataListener {
- private final SchemasChangedListener schemasChangedListener;
+ private final MetaDataChangedListener metaDataChangedListener;
private volatile RuleChangedListener ruleChangedListener;
@@ -42,7 +42,7 @@ public final class MetaDataListener {
public MetaDataListener(final ConfigurationRepository configurationRepository, final Collection<String> schemaNames) {
this.configurationRepository = configurationRepository;
- schemasChangedListener = new SchemasChangedListener(configurationRepository, schemaNames);
+ metaDataChangedListener = new MetaDataChangedListener(configurationRepository, schemaNames);
ruleChangedListener = new RuleChangedListener(configurationRepository, schemaNames);
dataSourceChangedListener = new DataSourceChangedListener(configurationRepository, schemaNames);
schemaChangedListener = new SchemaChangedListener(configurationRepository, schemaNames);
@@ -53,7 +53,7 @@ public final class MetaDataListener {
* watch event.
*/
public void watch() {
- schemasChangedListener.watch(Type.UPDATED);
+ metaDataChangedListener.watch(Type.UPDATED);
ruleChangedListener.watch(Type.UPDATED);
dataSourceChangedListener.watch(Type.UPDATED);
schemaChangedListener.watch(Type.UPDATED);