This is an automated email from the ASF dual-hosted git repository.
sunnianjun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
from ca402eb9c34 Reduce repeated calls to DataSourceMapperRuleAttribute
(#31617)
add b3a4f54c728 Add ComputeNodeOnlineWatcher and event subscriber (#31624)
No new revisions were added by this update.
Summary of changes:
.../online}/event/InstanceOfflineEvent.java | 2 +-
.../compute/online}/event/InstanceOnlineEvent.java | 2 +-
.../subscriber/ComputeNodeOnlineSubscriber.java | 56 ++++++++++++++
.../online/watcher/ComputeNodeOnlineWatcher.java | 84 +++++++++++++++++++++
.../watcher/ComputeNodeStateChangedWatcher.java | 31 --------
.../subscriber/ClusterEventSubscriberRegistry.java | 4 +-
.../subscriber/StateChangedSubscriber.java | 24 ------
....cluster.coordinator.registry.GovernanceWatcher | 1 +
.../ComputeNodeOnlineSubscriberTest.java} | 87 +++++++++-------------
.../watcher/ComputeNodeOnlineWatcherTest.java | 61 +++++++++++++++
.../subscriber/StateChangedSubscriberTest.java | 27 -------
11 files changed, 243 insertions(+), 136 deletions(-)
rename
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/{status/compute
=> nodes/compute/online}/event/InstanceOfflineEvent.java (96%)
rename
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/{status/compute
=> nodes/compute/online}/event/InstanceOnlineEvent.java (96%)
create mode 100644
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/subscriber/ComputeNodeOnlineSubscriber.java
create mode 100644
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/watcher/ComputeNodeOnlineWatcher.java
copy
mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/{subscriber/ResourceMetaDataChangedSubscriberTest.java
=>
registry/nodes/compute/online/subscriber/ComputeNodeOnlineSubscriberTest.java}
(51%)
create mode 100644
mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/watcher/ComputeNodeOnlineWatcherTest.java
