You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by wu...@apache.org on 2021/05/31 15:22:01 UTC
[shardingsphere] branch master updated (fb81efb -> f1b1b63)
This is an automated email from the ASF dual-hosted git repository.
wuweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from fb81efb Fix scaling-it (#10593)
new 9ecd81a Fix test case error for #10588
new 6fb4127 Rename PostGovernanceRepositoryEventListenerTest
new a52cc18 Refactor StatesNode
new 95bd638 Move GovernanceListenerFactory
new 75da68b Refactor GovernanceListenerFactory
new 22ab484 Rename GovernanceListenerBuilder
new 656c14b Rename AbstractGovernanceListener
new d656ecd Rename GovernanceListener
new 45a818d Refactor GovernanceListenerManager
new 67bc8bc Refactor GovernanceListenerManager
new 48c791a Refactor GovernanceListenerManager
new 6e93a83 Refactor GovernanceListener
new 6291f76 Refactor GovernanceListener
new da0ad80 Refactor GovernanceListener.getWatchingKeys
new 56b0f4a Refactor GovernanceListenerBuilder
new 845fe0d Refactor GovernanceListenerBuilder
new 50c6664 Refactor GovernanceListenerBuilder
new b417323 Merge GovernanceListenerBuilder and GovernanceListener
new 39ab839 Rename GovernanceListenerFactory
new acc961e Rename GovernanceWatcher
new 7cd1c9e Rename GovernanceWatcher.createGovernanceEvent
new 7f14ff3 Rename test cases
new f1b1b63 Merge pull request #10594 from terrymanu/dev
The 28947 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
...tener.java => PrivilegeNodeChangedWatcher.java} | 22 +++---
.../listener/event/AuthorityChangedEvent.java | 2 +-
.../PrivilegeNodeChangedListenerFactory.java | 43 -----------
.../metadata/GovernanceMetaDataContexts.java | 22 +++---
.../process/GovernanceExecuteProcessReporter.java | 6 +-
.../transaction/GovernanceTransactionContexts.java | 2 +-
...rnance.core.registry.watcher.GovernanceWatcher} | 2 +-
.../listener/PrivilegeNodeChangedListenerTest.java | 6 +-
.../metadata/GovernanceMetaDataContextsTest.java | 16 ++---
.../GovernanceTransactionContextsTest.java | 2 +-
.../governance/core/GovernanceFacade.java | 8 +--
.../core/lock/ShardingSphereDistributeLock.java | 6 +-
.../registry/cache/ScalingRegistrySubscriber.java | 6 +-
.../core/registry/listener/GovernanceListener.java | 33 ---------
.../listener/GovernanceListenerManager.java | 55 --------------
.../PostGovernanceRepositoryEventListener.java | 60 ----------------
.../DataSourceStateChangedListenerFactory.java | 43 -----------
.../factory/GlobalRuleChangedListenerFactory.java | 42 -----------
.../factory/LockChangedListenerFactory.java | 43 -----------
.../factory/MetaDataChangedListenerFactory.java | 43 -----------
.../factory/PropertiesChangedListenerFactory.java | 43 -----------
.../TerminalStateChangedListenerFactory.java | 43 -----------
.../config/impl/DataSourceRegistryService.java | 4 +-
.../config/impl/SchemaRuleRegistryService.java | 2 +-
.../service/process/ProcessRegistrySubscriber.java | 10 +--
.../service/schema/SchemaRegistryService.java | 4 +-
.../core/registry/service/state/StatesNode.java | 12 ++--
.../GovernanceWatcher.java} | 32 ++++++---
.../registry/watcher/GovernanceWatcherFactory.java | 63 ++++++++++++++++
.../event/GovernanceEvent.java | 2 +-
.../event/datasource/DataSourceAddedEvent.java | 2 +-
.../event/datasource/DataSourceAlteredEvent.java | 2 +-
.../datasource/DataSourceChangeCompletedEvent.java | 4 +-
.../event/datasource/DataSourceChangedEvent.java | 4 +-
.../invocation/ExecuteProcessReportEvent.java | 2 +-
.../ExecuteProcessSummaryReportEvent.java | 2 +-
.../invocation/ExecuteProcessUnitReportEvent.java | 2 +-
.../invocation/ShowProcessListRequestEvent.java | 2 +-
.../invocation/ShowProcessListResponseEvent.java | 2 +-
.../event/lock/LockNotificationEvent.java | 4 +-
.../event/lock/LockReleasedEvent.java | 4 +-
.../event/metadata/MetaDataChangedEvent.java | 2 +-
.../event/metadata/MetaDataCreatedEvent.java | 2 +-
.../event/metadata/MetaDataDroppedEvent.java | 2 +-
.../event/metadata/SchemaAddedEvent.java | 4 +-
.../event/metadata/SchemaDeletedEvent.java | 4 +-
.../event/props/PropertiesChangedEvent.java | 4 +-
.../DisabledStateChangedEvent.java | 4 +-
.../PrimaryStateChangedEvent.java | 4 +-
.../rule/GlobalRuleConfigurationsChangedEvent.java | 4 +-
.../event/rule/RuleConfigurationCachedEvent.java | 4 +-
.../event/rule/RuleConfigurationsAlteredEvent.java | 2 +-
.../event/rule/RuleConfigurationsChangedEvent.java | 4 +-
.../event/rule/SwitchRuleConfigurationEvent.java | 2 +-
.../event/scaling/StartScalingEvent.java | 2 +-
.../event/schema/SchemaChangedEvent.java | 4 +-
.../impl/DataSourceStateChangedWatcher.java} | 28 +++++---
.../impl/GlobalRuleChangedWatcher.java} | 26 ++++---
.../impl/LockChangedWatcher.java} | 29 +++++---
.../impl/MetaDataChangedWatcher.java} | 37 ++++++----
.../impl/PropertiesChangedWatcher.java} | 27 ++++---
.../impl/TerminalStateChangedWatcher.java} | 23 +++---
...rnance.core.registry.watcher.GovernanceWatcher} | 12 ++--
.../governance/core/GovernanceFacadeTest.java | 20 +++---
...tRegistryCenterRepositoryEventListenerTest.java | 83 ----------------------
.../listener/impl/GovernanceListenerTest.java | 41 -----------
.../config/impl/DataSourceRegistryServiceTest.java | 4 +-
.../config/impl/SchemaRuleRegistryServiceTest.java | 2 +-
.../service/schema/SchemaRegistryServiceTest.java | 4 +-
.../impl/DataSourceStateChangedWatcherTest.java} | 13 ++--
.../impl/GlobalRuleChangedWatcherTest.java} | 34 +++++----
.../impl/LockChangedWatcherTest.java} | 10 ++-
.../impl/MetaDataChangedWatcherTest.java} | 19 ++---
.../impl/PropertiesChangedWatcherTest.java} | 12 ++--
.../impl/TerminalStateChangedWatcherTest.java} | 12 ++--
.../GovernanceShardingSphereDataSourceTest.java | 8 +--
.../mysql/executor/ShowProcessListExecutor.java | 4 +-
.../rdl/impl/AddResourceBackendHandler.java | 2 +-
.../AlterDatabaseDiscoveryRuleBackendHandler.java | 2 +-
.../rdl/impl/AlterEncryptRuleBackendHandler.java | 2 +-
.../AlterReadwriteSplittingRuleBackendHandler.java | 2 +-
...terShardingBindingTableRulesBackendHandler.java | 2 +-
...rShardingBroadcastTableRulesBackendHandler.java | 2 +-
.../impl/AlterShardingTableRuleBackendHandler.java | 2 +-
.../rdl/impl/CreateDatabaseBackendHandler.java | 2 +-
.../CreateDatabaseDiscoveryRuleBackendHandler.java | 2 +-
.../rdl/impl/CreateEncryptRuleBackendHandler.java | 2 +-
...CreateReadwriteSplittingRuleBackendHandler.java | 2 +-
...ateShardingBindingTableRulesBackendHandler.java | 2 +-
...eShardingBroadcastTableRulesBackendHandler.java | 2 +-
.../CreateShardingTableRuleBackendHandler.java | 2 +-
.../rdl/impl/DropDatabaseBackendHandler.java | 2 +-
.../DropDatabaseDiscoveryRuleBackendHandler.java | 2 +-
.../rdl/impl/DropEncryptRuleBackendHandler.java | 2 +-
.../DropReadwriteSplittingRuleBackendHandler.java | 2 +-
.../rdl/impl/DropResourceBackendHandler.java | 2 +-
...ropShardingBindingTableRulesBackendHandler.java | 2 +-
...pShardingBroadcastTableRulesBackendHandler.java | 2 +-
.../impl/DropShardingTableRuleBackendHandler.java | 2 +-
.../scaling/core/api/ScalingWorker.java | 4 +-
.../scaling/core/job/FinishedCheckJob.java | 2 +-
101 files changed, 387 insertions(+), 866 deletions(-)
rename shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/authority/listener/{PrivilegeNodeChangedListener.java => PrivilegeNodeChangedWatcher.java} (67%)
delete mode 100644 shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/authority/listener/factory/PrivilegeNodeChangedListenerFactory.java
rename shardingsphere-governance/shardingsphere-governance-context/src/main/resources/META-INF/services/{org.apache.shardingsphere.governance.core.registry.listener.GovernanceListenerFactory => org.apache.shardingsphere.governance.core.registry.watcher.GovernanceWatcher} (95%)
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/GovernanceListener.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/GovernanceListenerManager.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/PostGovernanceRepositoryEventListener.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/factory/DataSourceStateChangedListenerFactory.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/factory/GlobalRuleChangedListenerFactory.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/factory/LockChangedListenerFactory.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/factory/MetaDataChangedListenerFactory.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/factory/PropertiesChangedListenerFactory.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/listener/factory/TerminalStateChangedListenerFactory.java
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener/GovernanceListenerFactory.java => watcher/GovernanceWatcher.java} (59%)
create mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/watcher/GovernanceWatcherFactory.java
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/GovernanceEvent.java (92%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/datasource/DataSourceAddedEvent.java (93%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/datasource/DataSourceAlteredEvent.java (93%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/datasource/DataSourceChangeCompletedEvent.java (88%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/datasource/DataSourceChangedEvent.java (87%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/invocation/ExecuteProcessReportEvent.java (92%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/invocation/ExecuteProcessSummaryReportEvent.java (93%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/invocation/ExecuteProcessUnitReportEvent.java (93%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/invocation/ShowProcessListRequestEvent.java (92%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/invocation/ShowProcessListResponseEvent.java (92%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/lock/LockNotificationEvent.java (85%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/lock/LockReleasedEvent.java (85%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/metadata/MetaDataChangedEvent.java (92%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/metadata/MetaDataCreatedEvent.java (92%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/metadata/MetaDataDroppedEvent.java (92%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/metadata/SchemaAddedEvent.java (85%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/metadata/SchemaDeletedEvent.java (85%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/props/PropertiesChangedEvent.java (86%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/readwritesplitting/DisabledStateChangedEvent.java (86%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/readwritesplitting/PrimaryStateChangedEvent.java (86%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/rule/GlobalRuleConfigurationsChangedEvent.java (87%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/rule/RuleConfigurationCachedEvent.java (86%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/rule/RuleConfigurationsAlteredEvent.java (93%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/rule/RuleConfigurationsChangedEvent.java (87%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/rule/SwitchRuleConfigurationEvent.java (93%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/scaling/StartScalingEvent.java (94%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener => watcher}/event/schema/SchemaChangedEvent.java (87%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/DataSourceStateChangedListener.java => watcher/impl/DataSourceStateChangedWatcher.java} (64%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/GlobalRuleChangedListener.java => watcher/impl/GlobalRuleChangedWatcher.java} (67%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/LockChangedListener.java => watcher/impl/LockChangedWatcher.java} (62%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/MetaDataChangedListener.java => watcher/impl/MetaDataChangedWatcher.java} (80%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/PropertiesChangedListener.java => watcher/impl/PropertiesChangedWatcher.java} (56%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/TerminalStateChangedListener.java => watcher/impl/TerminalStateChangedWatcher.java} (64%)
rename shardingsphere-governance/shardingsphere-governance-core/src/main/resources/META-INF/services/{org.apache.shardingsphere.governance.core.registry.listener.GovernanceListenerFactory => org.apache.shardingsphere.governance.core.registry.watcher.GovernanceWatcher} (56%)
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/listener/PostRegistryCenterRepositoryEventListenerTest.java
delete mode 100644 shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/listener/impl/GovernanceListenerTest.java
rename shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/DataSourceStateChangedListenerTest.java => watcher/impl/DataSourceStateChangedWatcherTest.java} (73%)
rename shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/GlobalRuleChangedListenerTest.java => watcher/impl/GlobalRuleChangedWatcherTest.java} (58%)
rename shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/LockChangedListenerTest.java => watcher/impl/LockChangedWatcherTest.java} (70%)
rename shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/MetaDataChangedListenerTest.java => watcher/impl/MetaDataChangedWatcherTest.java} (65%)
rename shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/PropertiesChangedListenerTest.java => watcher/impl/PropertiesChangedWatcherTest.java} (74%)
rename shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/{listener/impl/TerminalStateChangedListenerTest.java => watcher/impl/TerminalStateChangedWatcherTest.java} (68%)