This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 08e06709833 Move config and datasource event from mode-core to
mode-api (#31952)
08e06709833 is described below
commit 08e06709833bcc9e8f9f3a2163306ec880f9d387
Author: Haoran Meng <[email protected]>
AuthorDate: Tue Jul 2 11:01:43 2024 +0800
Move config and datasource event from mode-core to mode-api (#31952)
---
.../ReadwriteSplittingStaticDataSourceRuleAttribute.java | 2 +-
.../dispatch}/config/AlterGlobalRuleConfigurationEvent.java | 2 +-
.../mode/event/dispatch}/config/AlterPropertiesEvent.java | 2 +-
.../dispatch}/datasource/nodes/AlterStorageNodeEvent.java | 2 +-
.../dispatch}/datasource/nodes/RegisterStorageNodeEvent.java | 2 +-
.../datasource/nodes/UnregisterStorageNodeEvent.java | 2 +-
.../qualified}/QualifiedDataSourceDeletedEvent.java | 2 +-
.../dispatch}/datasource/unit/AlterStorageUnitEvent.java | 2 +-
.../dispatch}/datasource/unit/RegisterStorageUnitEvent.java | 2 +-
.../datasource/unit/UnregisterStorageUnitEvent.java | 2 +-
.../coordinator/listener/MetaDataChangedListener.java | 12 ++++++------
.../global/event/builder/GlobalRuleDispatchEventBuilder.java | 2 +-
.../global/event/builder/PropertiesDispatchEventBuilder.java | 2 +-
.../internal/InternalQualifiedDataSourceSubscriber.java | 2 +-
.../subscriber/GlobalRuleConfigurationEventSubscriber.java | 2 +-
.../coordinator/subscriber/PropertiesEventSubscriber.java | 2 +-
.../coordinator/subscriber/StorageUnitEventSubscriber.java | 6 +++---
.../subscriber/QualifiedDataSourceStateSubscriberTest.java | 2 +-
18 files changed, 25 insertions(+), 25 deletions(-)
diff --git
a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/rule/attribute/ReadwriteSplittingStaticDataSourceRuleAttribute.java
b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/rule/attribute/ReadwriteSplittingStaticDataSourceRuleAttribute.java
index 699c9e7d1bc..ca78c851452 100644
---
a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/rule/attribute/ReadwriteSplittingStaticDataSourceRuleAttribute.java
+++
b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/rule/attribute/ReadwriteSplittingStaticDataSourceRuleAttribute.java
@@ -23,7 +23,7 @@ import
org.apache.shardingsphere.infra.instance.ComputeNodeInstanceContext;
import
org.apache.shardingsphere.infra.metadata.database.schema.QualifiedDataSource;
import
org.apache.shardingsphere.infra.rule.attribute.datasource.StaticDataSourceRuleAttribute;
import org.apache.shardingsphere.infra.state.datasource.DataSourceState;
-import
org.apache.shardingsphere.mode.event.node.QualifiedDataSourceDeletedEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.qualified.QualifiedDataSourceDeletedEvent;
import
org.apache.shardingsphere.readwritesplitting.exception.logic.ReadwriteSplittingDataSourceRuleNotFoundException;
import
org.apache.shardingsphere.readwritesplitting.rule.ReadwriteSplittingDataSourceGroupRule;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/config/AlterGlobalRuleConfigurationEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/config/AlterGlobalRuleConfigurationEvent.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/config/AlterGlobalRuleConfigurationEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/config/AlterGlobalRuleConfigurationEvent.java
index 5cc7b5cb6db..ed9c58f6aa4 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/config/AlterGlobalRuleConfigurationEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/config/AlterGlobalRuleConfigurationEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.config;
+package org.apache.shardingsphere.mode.event.dispatch.config;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/config/AlterPropertiesEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/config/AlterPropertiesEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/config/AlterPropertiesEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/config/AlterPropertiesEvent.java
index f2b1313a262..8127063d574 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/config/AlterPropertiesEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/config/AlterPropertiesEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.config;
+package org.apache.shardingsphere.mode.event.dispatch.config;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/AlterStorageNodeEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/AlterStorageNodeEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/AlterStorageNodeEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/AlterStorageNodeEvent.java
index 4b01e20efd9..13e5f67a68e 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/AlterStorageNodeEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/AlterStorageNodeEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.datasource.nodes;
+package org.apache.shardingsphere.mode.event.dispatch.datasource.nodes;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/RegisterStorageNodeEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/RegisterStorageNodeEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/RegisterStorageNodeEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/RegisterStorageNodeEvent.java
index 251ab29c887..0566da1fc94 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/RegisterStorageNodeEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/RegisterStorageNodeEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.datasource.nodes;
+package org.apache.shardingsphere.mode.event.dispatch.datasource.nodes;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/UnregisterStorageNodeEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/UnregisterStorageNodeEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/UnregisterStorageNodeEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/UnregisterStorageNodeEvent.java
index b1dc2ac6a88..ffc026fcb1e 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/nodes/UnregisterStorageNodeEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/nodes/UnregisterStorageNodeEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.datasource.nodes;
+package org.apache.shardingsphere.mode.event.dispatch.datasource.nodes;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/node/QualifiedDataSourceDeletedEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/qualified/QualifiedDataSourceDeletedEvent.java
similarity index 93%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/node/QualifiedDataSourceDeletedEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/qualified/QualifiedDataSourceDeletedEvent.java
index 57639b48ea7..ac1e4b1dee2 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/node/QualifiedDataSourceDeletedEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/qualified/QualifiedDataSourceDeletedEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.node;
+package org.apache.shardingsphere.mode.event.dispatch.datasource.qualified;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/AlterStorageUnitEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/AlterStorageUnitEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/AlterStorageUnitEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/AlterStorageUnitEvent.java
index d3153e66bf4..4ba8f92aa54 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/AlterStorageUnitEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/AlterStorageUnitEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.datasource.unit;
+package org.apache.shardingsphere.mode.event.dispatch.datasource.unit;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/RegisterStorageUnitEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/RegisterStorageUnitEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/RegisterStorageUnitEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/RegisterStorageUnitEvent.java
index b5c8d405165..8b4f9e7dbc6 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/RegisterStorageUnitEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/RegisterStorageUnitEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.datasource.unit;
+package org.apache.shardingsphere.mode.event.dispatch.datasource.unit;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/UnregisterStorageUnitEvent.java
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/UnregisterStorageUnitEvent.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/UnregisterStorageUnitEvent.java
rename to
mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/UnregisterStorageUnitEvent.java
index 8865754299d..c45b2366570 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/event/datasource/unit/UnregisterStorageUnitEvent.java
+++
b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/datasource/unit/UnregisterStorageUnitEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.event.datasource.unit;
+package org.apache.shardingsphere.mode.event.dispatch.datasource.unit;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java
index 22640dec9fb..58c2fc92c98 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java
@@ -27,12 +27,12 @@ import
org.apache.shardingsphere.metadata.persist.node.metadata.TableMetaDataNod
import
org.apache.shardingsphere.metadata.persist.node.metadata.ViewMetaDataNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
-import
org.apache.shardingsphere.mode.event.datasource.nodes.AlterStorageNodeEvent;
-import
org.apache.shardingsphere.mode.event.datasource.nodes.RegisterStorageNodeEvent;
-import
org.apache.shardingsphere.mode.event.datasource.nodes.UnregisterStorageNodeEvent;
-import
org.apache.shardingsphere.mode.event.datasource.unit.AlterStorageUnitEvent;
-import
org.apache.shardingsphere.mode.event.datasource.unit.RegisterStorageUnitEvent;
-import
org.apache.shardingsphere.mode.event.datasource.unit.UnregisterStorageUnitEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.nodes.AlterStorageNodeEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.nodes.RegisterStorageNodeEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.nodes.UnregisterStorageNodeEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.unit.AlterStorageUnitEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.unit.RegisterStorageUnitEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.unit.UnregisterStorageUnitEvent;
import
org.apache.shardingsphere.mode.event.schema.table.CreateOrAlterTableEvent;
import org.apache.shardingsphere.mode.event.schema.table.DropTableEvent;
import org.apache.shardingsphere.mode.event.schema.view.CreateOrAlterViewEvent;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/GlobalRuleDispatchEventBuilder.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/GlobalRuleDispatchEventBuilder.java
index 777e7f0dcf2..40cb732ef1f 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/GlobalRuleDispatchEventBuilder.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/GlobalRuleDispatchEventBuilder.java
@@ -22,7 +22,7 @@ import org.apache.shardingsphere.mode.path.GlobalNodePath;
import org.apache.shardingsphere.metadata.persist.node.GlobalNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
-import
org.apache.shardingsphere.mode.event.config.AlterGlobalRuleConfigurationEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.config.AlterGlobalRuleConfigurationEvent;
import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.DispatchEventBuilder;
import java.util.Arrays;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/PropertiesDispatchEventBuilder.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/PropertiesDispatchEventBuilder.java
index 5a78d488930..5faf4d8c556 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/PropertiesDispatchEventBuilder.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/global/event/builder/PropertiesDispatchEventBuilder.java
@@ -21,7 +21,7 @@ import org.apache.shardingsphere.mode.path.GlobalNodePath;
import org.apache.shardingsphere.metadata.persist.node.GlobalNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
-import org.apache.shardingsphere.mode.event.config.AlterPropertiesEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.config.AlterPropertiesEvent;
import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.DispatchEventBuilder;
import java.util.Arrays;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/storage/subscriber/internal/InternalQualifiedDataSourceSubscriber.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/storage/subscriber/internal/InternalQualifiedDataSourceSubscriber.java
index 50450cdd9b9..3a5522c2d5a 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/storage/subscriber/internal/InternalQualifiedDataSourceSubscriber.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/storage/subscriber/internal/InternalQualifiedDataSourceSubscriber.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.node
import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
-import
org.apache.shardingsphere.mode.event.node.QualifiedDataSourceDeletedEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.qualified.QualifiedDataSourceDeletedEvent;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import org.apache.shardingsphere.mode.storage.node.QualifiedDataSourceNode;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/GlobalRuleConfigurationEventSubscriber.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/GlobalRuleConfigurationEventSubscriber.java
index 58b89876b7d..33cd268e685 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/GlobalRuleConfigurationEventSubscriber.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/GlobalRuleConfigurationEventSubscriber.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.mode.manager.cluster.coordinator.subscriber;
import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
-import
org.apache.shardingsphere.mode.event.config.AlterGlobalRuleConfigurationEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.config.AlterGlobalRuleConfigurationEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
/**
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/PropertiesEventSubscriber.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/PropertiesEventSubscriber.java
index 80a16ff58d9..4e6961f4e25 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/PropertiesEventSubscriber.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/PropertiesEventSubscriber.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.mode.manager.cluster.coordinator.subscriber;
import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
-import org.apache.shardingsphere.mode.event.config.AlterPropertiesEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.config.AlterPropertiesEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
/**
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/StorageUnitEventSubscriber.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/StorageUnitEventSubscriber.java
index 717b790adc6..ab42cc760d4 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/StorageUnitEventSubscriber.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/StorageUnitEventSubscriber.java
@@ -20,9 +20,9 @@ package
org.apache.shardingsphere.mode.manager.cluster.coordinator.subscriber;
import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
-import
org.apache.shardingsphere.mode.event.datasource.unit.AlterStorageUnitEvent;
-import
org.apache.shardingsphere.mode.event.datasource.unit.RegisterStorageUnitEvent;
-import
org.apache.shardingsphere.mode.event.datasource.unit.UnregisterStorageUnitEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.unit.AlterStorageUnitEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.unit.RegisterStorageUnitEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.unit.UnregisterStorageUnitEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
/**
diff --git
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/storage/subscriber/QualifiedDataSourceStateSubscriberTest.java
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/storage/subscriber/QualifiedDataSourceStateSubscriberTest.java
index c0d6fc37a13..90b17dde1ff 100644
---
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/storage/subscriber/QualifiedDataSourceStateSubscriberTest.java
+++
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/storage/subscriber/QualifiedDataSourceStateSubscriberTest.java
@@ -18,7 +18,7 @@
package
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.storage.subscriber;
import
org.apache.shardingsphere.infra.metadata.database.schema.QualifiedDataSource;
-import
org.apache.shardingsphere.mode.event.node.QualifiedDataSourceDeletedEvent;
+import
org.apache.shardingsphere.mode.event.dispatch.datasource.qualified.QualifiedDataSourceDeletedEvent;
import
org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.storage.subscriber.internal.InternalQualifiedDataSourceSubscriber;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import org.apache.shardingsphere.mode.storage.node.QualifiedDataSourceNode;
