Mode dispatch events from cluster to mode api (#31961)

apache · Jul 2, 2024 · f085949 · f085949
1 parent 15e6a6a
commit f085949
Show file tree

Hide file tree

Showing 52 changed files with 100 additions and 100 deletions.
diff --git a/.../CreateDatabaseListenerAssistedEvent.java → .../CreateDatabaseListenerAssistedEvent.java b/.../CreateDatabaseListenerAssistedEvent.java → .../CreateDatabaseListenerAssistedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener;
+package org.apache.shardingsphere.mode.event.dispatch.assisted;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...er/DropDatabaseListenerAssistedEvent.java → ...ed/DropDatabaseListenerAssistedEvent.java b/...er/DropDatabaseListenerAssistedEvent.java → ...ed/DropDatabaseListenerAssistedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener;
+package org.apache.shardingsphere.mode.event.dispatch.assisted;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...ry/data/event/DatabaseDataAddedEvent.java → ...metadata/data/DatabaseDataAddedEvent.java b/...ry/data/event/DatabaseDataAddedEvent.java → ...metadata/data/DatabaseDataAddedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.data;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/.../data/event/DatabaseDataDeletedEvent.java → ...tadata/data/DatabaseDataDeletedEvent.java b/.../data/event/DatabaseDataDeletedEvent.java → ...tadata/data/DatabaseDataDeletedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.data;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...stry/data/event/SchemaDataAddedEvent.java → ...h/metadata/data/SchemaDataAddedEvent.java b/...stry/data/event/SchemaDataAddedEvent.java → ...h/metadata/data/SchemaDataAddedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.data;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...ry/data/event/SchemaDataDeletedEvent.java → ...metadata/data/SchemaDataDeletedEvent.java b/...ry/data/event/SchemaDataDeletedEvent.java → ...metadata/data/SchemaDataDeletedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.data;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...nt/ShardingSphereRowDataChangedEvent.java → ...ta/ShardingSphereRowDataChangedEvent.java b/...nt/ShardingSphereRowDataChangedEvent.java → ...ta/ShardingSphereRowDataChangedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.data;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...nt/ShardingSphereRowDataDeletedEvent.java → ...ta/ShardingSphereRowDataDeletedEvent.java b/...nt/ShardingSphereRowDataDeletedEvent.java → ...ta/ShardingSphereRowDataDeletedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.data;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...try/data/event/TableDataChangedEvent.java → .../metadata/data/TableDataChangedEvent.java b/...try/data/event/TableDataChangedEvent.java → .../metadata/data/TableDataChangedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.data;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...stry/metadata/event/SchemaAddedEvent.java → ...tch/metadata/schema/SchemaAddedEvent.java b/...stry/metadata/event/SchemaAddedEvent.java → ...tch/metadata/schema/SchemaAddedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.metadata.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.schema;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...ry/metadata/event/SchemaDeletedEvent.java → ...h/metadata/schema/SchemaDeletedEvent.java b/...ry/metadata/event/SchemaDeletedEvent.java → ...h/metadata/schema/SchemaDeletedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.metadata.event;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.schema;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...schema/table/CreateOrAlterTableEvent.java → ...schema/table/CreateOrAlterTableEvent.java b/...schema/table/CreateOrAlterTableEvent.java → ...schema/table/CreateOrAlterTableEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.event.dispatch.schema.table;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.schema.table;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...dispatch/schema/table/DropTableEvent.java → ...metadata/schema/table/DropTableEvent.java b/...dispatch/schema/table/DropTableEvent.java → ...metadata/schema/table/DropTableEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.event.dispatch.schema.table;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.schema.table;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...h/schema/view/CreateOrAlterViewEvent.java → ...a/schema/view/CreateOrAlterViewEvent.java b/...h/schema/view/CreateOrAlterViewEvent.java → ...a/schema/view/CreateOrAlterViewEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.event.dispatch.schema.view;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.schema.view;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...t/dispatch/schema/view/DropViewEvent.java → ...h/metadata/schema/view/DropViewEvent.java b/...t/dispatch/schema/view/DropViewEvent.java → ...h/metadata/schema/view/DropViewEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.event.dispatch.schema.view;
+package org.apache.shardingsphere.mode.event.dispatch.metadata.schema.view;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...atus/cluster/event/ClusterStateEvent.java → ...atch/state/cluster/ClusterStateEvent.java b/...atus/cluster/event/ClusterStateEvent.java → ...atch/state/cluster/ClusterStateEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.cluster;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...ComputeNodeInstanceStateChangedEvent.java → ...ComputeNodeInstanceStateChangedEvent.java b/...ComputeNodeInstanceStateChangedEvent.java → ...ComputeNodeInstanceStateChangedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...event/KillLocalProcessCompletedEvent.java → ...mpute/KillLocalProcessCompletedEvent.java b/...event/KillLocalProcessCompletedEvent.java → ...mpute/KillLocalProcessCompletedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/.../compute/event/KillLocalProcessEvent.java → .../state/compute/KillLocalProcessEvent.java b/.../compute/event/KillLocalProcessEvent.java → .../state/compute/KillLocalProcessEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...try/status/compute/event/LabelsEvent.java → ...t/dispatch/state/compute/LabelsEvent.java b/...try/status/compute/event/LabelsEvent.java → ...t/dispatch/state/compute/LabelsEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...t/ReportLocalProcessesCompletedEvent.java → ...e/ReportLocalProcessesCompletedEvent.java b/...t/ReportLocalProcessesCompletedEvent.java → ...e/ReportLocalProcessesCompletedEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...pute/event/ReportLocalProcessesEvent.java → ...te/compute/ReportLocalProcessesEvent.java b/...pute/event/ReportLocalProcessesEvent.java → ...te/compute/ReportLocalProcessesEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...y/status/compute/event/WorkerIdEvent.java → ...dispatch/state/compute/WorkerIdEvent.java b/...y/status/compute/event/WorkerIdEvent.java → ...dispatch/state/compute/WorkerIdEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...te/online/event/InstanceOfflineEvent.java → ...ompute/instance/InstanceOfflineEvent.java b/...te/online/event/InstanceOfflineEvent.java → ...ompute/instance/InstanceOfflineEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.compute.online.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute.instance;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...ute/online/event/InstanceOnlineEvent.java → ...compute/instance/InstanceOnlineEvent.java b/...ute/online/event/InstanceOnlineEvent.java → ...compute/instance/InstanceOnlineEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.compute.online.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.compute.instance;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/.../event/QualifiedDataSourceStateEvent.java → ...torage/QualifiedDataSourceStateEvent.java b/.../event/QualifiedDataSourceStateEvent.java → ...torage/QualifiedDataSourceStateEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.storage.event;
+package org.apache.shardingsphere.mode.event.dispatch.state.storage;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

diff --git a/...che/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java b/...che/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java
@@ -33,12 +33,12 @@
 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.dispatch.schema.table.CreateOrAlterTableEvent;
-import org.apache.shardingsphere.mode.event.dispatch.schema.table.DropTableEvent;
-import org.apache.shardingsphere.mode.event.dispatch.schema.view.CreateOrAlterViewEvent;
-import org.apache.shardingsphere.mode.event.dispatch.schema.view.DropViewEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.metadata.event.SchemaAddedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.metadata.event.SchemaDeletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.table.CreateOrAlterTableEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.table.DropTableEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.view.CreateOrAlterViewEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.view.DropViewEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.SchemaAddedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.SchemaDeletedEvent;
 import org.apache.shardingsphere.mode.event.builder.RuleConfigurationEventBuilder;
 import org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener;
 

diff --git a/...nager/cluster/coordinator/listener/processor/CreateDatabaseListenerAssistedProcessor.java b/...nager/cluster/coordinator/listener/processor/CreateDatabaseListenerAssistedProcessor.java
@@ -19,7 +19,7 @@
 
 import org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode;
 import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener.CreateDatabaseListenerAssistedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.assisted.CreateDatabaseListenerAssistedEvent;
 
 /**
  * Create database listener assisted processor.

diff --git a/...manager/cluster/coordinator/listener/processor/DropDatabaseListenerAssistedProcessor.java b/...manager/cluster/coordinator/listener/processor/DropDatabaseListenerAssistedProcessor.java
@@ -19,7 +19,7 @@
 
 import org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode;
 import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener.DropDatabaseListenerAssistedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.assisted.DropDatabaseListenerAssistedEvent;
 
 /**
  * Drop database listener assisted processor.

diff --git a/...e/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java b/...e/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java
@@ -24,7 +24,7 @@
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.builder.dispatch.DispatchEventBuilder;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.event.ClusterStateEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.cluster.ClusterStateEvent;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...rdingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilder.java b/...rdingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilder.java
@@ -29,8 +29,8 @@
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.builder.dispatch.DispatchEventBuilder;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.compute.online.event.InstanceOfflineEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.compute.online.event.InstanceOnlineEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.instance.InstanceOfflineEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.instance.InstanceOnlineEvent;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...ardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilder.java b/...ardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilder.java
@@ -24,13 +24,13 @@
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.builder.dispatch.DispatchEventBuilder;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.ComputeNodeInstanceStateChangedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.KillLocalProcessCompletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.KillLocalProcessEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.LabelsEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.ReportLocalProcessesCompletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.ReportLocalProcessesEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.WorkerIdEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.ComputeNodeInstanceStateChangedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.KillLocalProcessCompletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.KillLocalProcessEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.LabelsEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.ReportLocalProcessesCompletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.ReportLocalProcessesEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.WorkerIdEvent;
 
 import java.util.ArrayList;
 import java.util.Arrays;

diff --git a/...ardingsphere/mode/manager/cluster/event/builder/ListenerAssistedDispatchEventBuilder.java b/...ardingsphere/mode/manager/cluster/event/builder/ListenerAssistedDispatchEventBuilder.java
@@ -22,8 +22,8 @@
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.builder.dispatch.DispatchEventBuilder;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener.DropDatabaseListenerAssistedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener.CreateDatabaseListenerAssistedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.assisted.DropDatabaseListenerAssistedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.assisted.CreateDatabaseListenerAssistedEvent;
 import org.apache.shardingsphere.mode.persist.pojo.ListenerAssistedType;
 import org.apache.shardingsphere.mode.persist.pojo.ListenerAssistedPOJO;
 import org.apache.shardingsphere.mode.path.ListenerAssistedNodePath;

diff --git a/...ingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilder.java b/...ingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilder.java
@@ -24,7 +24,7 @@
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.builder.dispatch.DispatchEventBuilder;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.storage.event.QualifiedDataSourceStateEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.storage.QualifiedDataSourceStateEvent;
 import org.apache.shardingsphere.infra.state.datasource.qualified.QualifiedDataSourceState;
 import org.apache.shardingsphere.mode.storage.node.QualifiedDataSourceNode;
 import org.apache.shardingsphere.infra.state.datasource.qualified.yaml.YamlQualifiedDataSourceState;

diff --git a/...dingsphere/mode/manager/cluster/event/builder/ShardingSphereDataDispatchEventBuilder.java b/...dingsphere/mode/manager/cluster/event/builder/ShardingSphereDataDispatchEventBuilder.java
@@ -24,13 +24,13 @@
 import org.apache.shardingsphere.metadata.persist.node.ShardingSphereDataNode;
 import org.apache.shardingsphere.infra.rule.event.GovernanceEvent;
 import org.apache.shardingsphere.mode.event.builder.dispatch.DispatchEventBuilder;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.DatabaseDataAddedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.DatabaseDataDeletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.SchemaDataAddedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.SchemaDataDeletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.ShardingSphereRowDataChangedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.ShardingSphereRowDataDeletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.TableDataChangedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.DatabaseDataAddedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.DatabaseDataDeletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.SchemaDataAddedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.SchemaDataDeletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.ShardingSphereRowDataChangedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.ShardingSphereRowDataDeletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.TableDataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 

diff --git a/...ingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriber.java b/...ingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriber.java
@@ -22,8 +22,8 @@
 import org.apache.shardingsphere.infra.instance.ComputeNodeInstance;
 import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
 import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.compute.online.event.InstanceOfflineEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.nodes.compute.online.event.InstanceOnlineEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.instance.InstanceOfflineEvent;
+import org.apache.shardingsphere.mode.event.dispatch.state.compute.instance.InstanceOnlineEvent;
 
 /**
  * Compute node online subscriber.

diff --git a/...rdingsphere/mode/manager/cluster/event/subscriber/dispatch/DatabaseChangedSubscriber.java b/...rdingsphere/mode/manager/cluster/event/subscriber/dispatch/DatabaseChangedSubscriber.java
@@ -21,13 +21,13 @@
 import lombok.RequiredArgsConstructor;
 import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
 import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.DatabaseDataAddedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.DatabaseDataDeletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.SchemaDataAddedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.SchemaDataDeletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.ShardingSphereRowDataChangedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.ShardingSphereRowDataDeletedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.data.event.TableDataChangedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.DatabaseDataAddedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.DatabaseDataDeletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.SchemaDataAddedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.SchemaDataDeletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.ShardingSphereRowDataChangedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.ShardingSphereRowDataDeletedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.metadata.data.TableDataChangedEvent;
 
 /**
  * Database changed subscriber.

diff --git a/.../manager/cluster/event/subscriber/dispatch/ListenerAssistedMetaDataChangedSubscriber.java b/.../manager/cluster/event/subscriber/dispatch/ListenerAssistedMetaDataChangedSubscriber.java
@@ -24,8 +24,8 @@
 import org.apache.shardingsphere.mode.manager.ContextManager;
 import org.apache.shardingsphere.mode.manager.cluster.coordinator.listener.MetaDataWatchListenerManager;
 import org.apache.shardingsphere.mode.manager.cluster.coordinator.listener.processor.ListenerAssistedProcessor;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener.DropDatabaseListenerAssistedEvent;
-import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener.CreateDatabaseListenerAssistedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.assisted.DropDatabaseListenerAssistedEvent;
+import org.apache.shardingsphere.mode.event.dispatch.assisted.CreateDatabaseListenerAssistedEvent;
 import org.apache.shardingsphere.mode.manager.cluster.coordinator.listener.MetaDataChangedListener;
 import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;