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
