You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by su...@apache.org on 2024/06/07 08:10:07 UTC
(shardingsphere) branch master updated (ca402eb9c34 -> b3a4f54c728)
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