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 2023/06/05 06:14:16 UTC
[shardingsphere] branch master updated (5cb6ea29cf9 -> b0a29fc07f2)
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 5cb6ea29cf9 Support partition_less_than_item in openGauss sql parser (#25997)
add b0a29fc07f2 Add RuleConfigurationEventBuilder to build feature configuration changed event. (#25998)
No new revisions were added by this update.
Summary of changes:
...riteSplittingRuleConfigurationEventBuilder.java | 82 ++++++++++++++++++++
.../AddReadwriteSplittingConfigurationEvent.java | 10 ++-
.../AlterReadwriteSplittingConfigurationEvent.java | 12 +--
...DeleteReadwriteSplittingConfigurationEvent.java | 8 +-
.../event}/loadbalance/AddLoadBalanceEvent.java | 10 ++-
.../event}/loadbalance/AlterLoadBalanceEvent.java | 12 +--
.../event}/loadbalance/DeleteLoadBalanceEvent.java | 8 +-
.../converter/ReadwriteSplittingNodeConverter.java | 90 ++++++++++++++++++++++
.../ReadwriteSplittingConfigurationSubscriber.java | 29 ++++---
.../ReadwriteSplittingLoadBalanceSubscriber.java | 25 +++---
...ReadwriteSplittingRuleConfigurationSwapper.java | 8 +-
...mode.event.config.RuleConfigurationEventBuilder | 18 +++++
.../ReadwriteSplittingNodeConverterTest.java | 58 ++++++++++++++
...writeSplittingRuleConfigurationSwapperTest.java | 6 +-
.../metadata/converter/ShardingNodeConverter.java | 52 ++++++-------
.../NewYamlShardingRuleConfigurationSwapper.java | 51 ++++--------
...ewYamlShardingRuleConfigurationSwapperTest.java | 28 +++----
.../builder/database/DatabaseRulesBuilder.java | 27 +++++++
.../infra/rule/event}/GovernanceEvent.java | 2 +-
.../metadata/node/PipelineMetaDataNodeWatcher.java | 2 +-
.../ChangedJobConfigurationProcessor.java | 2 +-
.../AbstractChangedJobConfigurationProcessor.java | 2 +-
.../PipelineMetaDataChangedEventHandler.java | 2 +-
.../impl/BarrierMetaDataChangedEventHandler.java | 4 +-
.../impl/ConfigMetaDataChangedEventHandler.java | 2 +-
.../persist/node/NewDatabaseMetaDataNode.java | 47 +++++++----
.../ReadwriteSplittingNodeConverter.java | 48 ------------
.../persist/node/NewDatabaseMetaDataNodeTest.java | 14 +++-
.../mode/event}/DataChangedEvent.java | 2 +-
.../config/RuleConfigurationChangedEvent.java} | 12 +--
.../config/RuleConfigurationEventBuilder.java} | 19 +++--
.../mode/event/rule/FeatureEvent.java | 24 ------
.../cluster/NewClusterContextManagerBuilder.java | 8 +-
.../coordinator/registry/GovernanceWatcher.java | 4 +-
.../coordinator/registry/NewGovernanceWatcher.java | 4 +-
.../event/datasource/DataSourceChangedEvent.java | 2 +-
.../config/event/props/PropertiesChangedEvent.java | 2 +-
.../rule/GlobalRuleConfigurationsChangedEvent.java | 2 +-
.../event/rule/RuleConfigurationsChangedEvent.java | 2 +-
.../LoadBalanceConfigurationChangedEvent.java} | 12 +--
.../event/schema/TableMetaDataChangedEvent.java | 2 +-
.../event/schema/ViewMetaDataChangedEvent.java | 2 +-
.../event/version/DatabaseVersionChangedEvent.java | 2 +-
.../config/watcher/GlobalRuleChangedWatcher.java | 4 +-
.../config/watcher/PropertiesChangedWatcher.java | 4 +-
.../data/ShardingSphereDataChangedWatcher.java | 6 +-
.../data/event/DatabaseDataAddedEvent.java | 2 +-
.../data/event/DatabaseDataDeletedEvent.java | 2 +-
.../registry/data/event/SchemaDataAddedEvent.java | 2 +-
.../data/event/SchemaDataDeletedEvent.java | 2 +-
.../event/ShardingSphereRowDataChangedEvent.java | 2 +-
.../event/ShardingSphereRowDataDeletedEvent.java | 2 +-
.../registry/data/event/TableDataChangedEvent.java | 2 +-
.../metadata/event/DatabaseAddedEvent.java | 2 +-
.../metadata/event/DatabaseDeletedEvent.java | 2 +-
.../registry/metadata/event/SchemaAddedEvent.java | 2 +-
.../metadata/event/SchemaDeletedEvent.java | 2 +-
.../metadata/watcher/MetaDataChangedWatcher.java | 6 +-
.../watcher/NewMetaDataChangedWatcher.java | 27 ++++++-
.../cluster/event/ClusterLockDeletedEvent.java | 2 +-
.../status/cluster/event/ClusterStateEvent.java | 2 +-
.../watcher/ClusterStateChangedWatcher.java | 6 +-
.../status/compute/event/InstanceOfflineEvent.java | 2 +-
.../status/compute/event/InstanceOnlineEvent.java | 2 +-
.../event/KillLocalProcessCompletedEvent.java | 2 +-
.../compute/event/KillLocalProcessEvent.java | 2 +-
.../registry/status/compute/event/LabelsEvent.java | 2 +-
.../event/ReportLocalProcessesCompletedEvent.java | 2 +-
.../compute/event/ReportLocalProcessesEvent.java | 2 +-
.../registry/status/compute/event/StateEvent.java | 2 +-
.../status/compute/event/WorkerIdEvent.java | 2 +-
.../watcher/ComputeNodeStateChangedWatcher.java | 6 +-
.../storage/event/StorageNodeChangedEvent.java | 2 +-
.../watcher/StorageNodeStateChangedWatcher.java | 6 +-
.../subscriber/CacheEvictedSubscriber.java | 2 +-
.../NewConfigurationChangedSubscriber.java | 53 +++++++++++++
.../NewContextManagerSubscriberFacade.java | 5 +-
.../watcher/GlobalRuleChangedWatcherTest.java | 4 +-
.../watcher/PropertiesChangedWatcherTest.java | 4 +-
.../watcher/MetaDataChangedWatcherTest.java | 6 +-
.../watcher/ClusterStateChangedWatcherTest.java | 6 +-
.../ComputeNodeStateChangedWatcherTest.java | 6 +-
.../StorageNodeStateChangedWatcherTest.java | 6 +-
.../cluster/listener/DataChangedEventListener.java | 2 +
.../cluster/consul/ConsulRepository.java | 2 +-
.../repository/cluster/etcd/EtcdRepository.java | 4 +-
.../nacos/listener/NamingEventListener.java | 4 +-
.../cluster/nacos/NacosRepositoryTest.java | 2 +-
.../cluster/zookeeper/ZookeeperRepository.java | 4 +-
.../cluster/zookeeper/ZookeeperRepositoryTest.java | 4 +-
.../api/impl/GovernanceRepositoryAPIImplTest.java | 4 +-
91 files changed, 649 insertions(+), 338 deletions(-)
create mode 100644 features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/event/ReadwriteSplittingRuleConfigurationEventBuilder.java
rename {mode/core/src/main/java/org/apache/shardingsphere/mode/event/rule/readwritesplitting/configuration => features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/event/config}/AddReadwriteSplittingConfigurationEvent.java (76%)
rename {mode/core/src/main/java/org/apache/shardingsphere/mode/event/rule/readwritesplitting/configuration => features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/event/config}/AlterReadwriteSplittingConfigurationEvent.java (73%)
rename {mode/core/src/main/java/org/apache/shardingsphere/mode/event/rule/readwritesplitting/configuration => features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/event/config}/DeleteReadwriteSplittingConfigurationEvent.java (82%)
rename {mode/core/src/main/java/org/apache/shardingsphere/mode/event/rule/readwritesplitting => features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/event}/loadbalance/AddLoadBalanceEvent.java (78%)
copy {mode/core/src/main/java/org/apache/shardingsphere/mode/event/rule/readwritesplitting => features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/event}/loadbalance/AlterLoadBalanceEvent.java (76%)
rename {mode/core/src/main/java/org/apache/shardingsphere/mode/event/rule/readwritesplitting => features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/event}/loadbalance/DeleteLoadBalanceEvent.java (80%)
create mode 100644 features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/metadata/converter/ReadwriteSplittingNodeConverter.java
create mode 100644 features/readwrite-splitting/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.event.config.RuleConfigurationEventBuilder
create mode 100644 features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/metadata/converter/ReadwriteSplittingNodeConverterTest.java
rename {mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry => infra/common/src/main/java/org/apache/shardingsphere/infra/rule/event}/GovernanceEvent.java (91%)
delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/node/metadata/config/readwritesplitting/ReadwriteSplittingNodeConverter.java
rename mode/{type/cluster/repository/api/src/main/java/org/apache/shardingsphere/mode/repository/cluster/listener => core/src/main/java/org/apache/shardingsphere/mode/event}/DataChangedEvent.java (94%)
copy mode/{type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/event/DatabaseAddedEvent.java => core/src/main/java/org/apache/shardingsphere/mode/event/config/RuleConfigurationChangedEvent.java} (77%)
copy mode/{type/cluster/repository/api/src/main/java/org/apache/shardingsphere/mode/repository/cluster/listener/DataChangedEventListener.java => core/src/main/java/org/apache/shardingsphere/mode/event/config/RuleConfigurationEventBuilder.java} (63%)
delete mode 100644 mode/core/src/main/java/org/apache/shardingsphere/mode/event/rule/FeatureEvent.java
rename mode/{core/src/main/java/org/apache/shardingsphere/mode/event/rule/readwritesplitting/loadbalance/AlterLoadBalanceEvent.java => type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/config/event/rule/readwritesplitting/LoadBalanceConfigurationChangedEvent.java} (76%)
create mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/NewConfigurationChangedSubscriber.java