Refactor mode event package (#34034)

* Refactor mode event package * Refactor mode event package
apache · Dec 12, 2024 · 9b9af8e · 9b9af8e
1 parent 2e2e400
commit 9b9af8e
Show file tree

Hide file tree

Showing 55 changed files with 88 additions and 61 deletions.
diff --git a/.../mode/manager/cluster/event/deliver/subscriber/ClusterDeliverEventSubscriberRegistry.java b/.../mode/manager/cluster/event/deliver/subscriber/ClusterDeliverEventSubscriberRegistry.java
@@ -19,6 +19,7 @@
 
 import lombok.Getter;
 import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber.type.DeliverQualifiedDataSourceSubscriber;
 import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
 
 import java.util.Collection;

diff --git a/...DeliverQualifiedDataSourceSubscriber.java → ...DeliverQualifiedDataSourceSubscriber.java b/...DeliverQualifiedDataSourceSubscriber.java → ...DeliverQualifiedDataSourceSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import lombok.RequiredArgsConstructor;

diff --git a/...der/ClusterStateDispatchEventBuilder.java → ...ype/ClusterStateDispatchEventBuilder.java b/...der/ClusterStateDispatchEventBuilder.java → ...ype/ClusterStateDispatchEventBuilder.java
@@ -15,14 +15,15 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import org.apache.shardingsphere.infra.state.cluster.ClusterState;
 import org.apache.shardingsphere.metadata.persist.node.StatesNode;
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;
 import org.apache.shardingsphere.mode.event.dispatch.state.cluster.ClusterStateEvent;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...omputeNodeOnlineDispatchEventBuilder.java → ...omputeNodeOnlineDispatchEventBuilder.java b/...omputeNodeOnlineDispatchEventBuilder.java → ...omputeNodeOnlineDispatchEventBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import org.apache.shardingsphere.infra.instance.ComputeNodeData;
 import org.apache.shardingsphere.infra.instance.metadata.InstanceMetaData;
@@ -30,6 +30,7 @@
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;
 import org.apache.shardingsphere.mode.event.dispatch.state.compute.instance.InstanceOfflineEvent;
 import org.apache.shardingsphere.mode.event.dispatch.state.compute.instance.InstanceOnlineEvent;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...ComputeNodeStateDispatchEventBuilder.java → ...ComputeNodeStateDispatchEventBuilder.java b/...ComputeNodeStateDispatchEventBuilder.java → ...ComputeNodeStateDispatchEventBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import com.google.common.base.Strings;
 import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
@@ -26,6 +26,7 @@
 import org.apache.shardingsphere.mode.event.dispatch.state.compute.ComputeNodeInstanceStateChangedEvent;
 import org.apache.shardingsphere.mode.event.dispatch.state.compute.LabelsEvent;
 import org.apache.shardingsphere.mode.event.dispatch.state.compute.WorkerIdEvent;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 
 import java.util.ArrayList;
 import java.util.Arrays;

diff --git a/...ilder/GlobalRuleDispatchEventBuilder.java → .../type/GlobalRuleDispatchEventBuilder.java b/...ilder/GlobalRuleDispatchEventBuilder.java → .../type/GlobalRuleDispatchEventBuilder.java
@@ -15,13 +15,14 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 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.dispatch.DispatchEvent;
 import org.apache.shardingsphere.mode.event.dispatch.config.AlterGlobalRuleConfigurationEvent;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 import org.apache.shardingsphere.mode.path.GlobalNodePath;
 
 import java.util.Arrays;

diff --git a/...lder/KillProcessDispatchEventBuilder.java → ...type/KillProcessDispatchEventBuilder.java b/...lder/KillProcessDispatchEventBuilder.java → ...type/KillProcessDispatchEventBuilder.java
@@ -15,14 +15,15 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;
 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.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...ListenerAssistedDispatchEventBuilder.java → ...ListenerAssistedDispatchEventBuilder.java b/...ListenerAssistedDispatchEventBuilder.java → ...ListenerAssistedDispatchEventBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
 import org.apache.shardingsphere.metadata.persist.node.StatesNode;
@@ -24,6 +24,7 @@
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;
 import org.apache.shardingsphere.mode.event.dispatch.assisted.CreateDatabaseListenerAssistedEvent;
 import org.apache.shardingsphere.mode.event.dispatch.assisted.DropDatabaseListenerAssistedEvent;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 import org.apache.shardingsphere.mode.persist.pojo.ListenerAssisted;
 import org.apache.shardingsphere.mode.persist.pojo.ListenerAssistedType;
 

diff --git a/...ilder/PropertiesDispatchEventBuilder.java → .../type/PropertiesDispatchEventBuilder.java b/...ilder/PropertiesDispatchEventBuilder.java → .../type/PropertiesDispatchEventBuilder.java
@@ -15,12 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 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.dispatch.config.AlterPropertiesEvent;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 import org.apache.shardingsphere.mode.path.GlobalNodePath;
 
 import java.util.Arrays;

diff --git a/...lifiedDataSourceDispatchEventBuilder.java → ...lifiedDataSourceDispatchEventBuilder.java b/...lifiedDataSourceDispatchEventBuilder.java → ...lifiedDataSourceDispatchEventBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import com.google.common.base.Strings;
 import org.apache.shardingsphere.infra.metadata.database.schema.QualifiedDataSource;
@@ -28,6 +28,7 @@
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;
 import org.apache.shardingsphere.mode.event.dispatch.state.storage.QualifiedDataSourceStateEvent;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...ardingSphereDataDispatchEventBuilder.java → ...ardingSphereDataDispatchEventBuilder.java b/...ardingSphereDataDispatchEventBuilder.java → ...ardingSphereDataDispatchEventBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import com.google.common.base.Strings;
 import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
@@ -31,6 +31,7 @@
 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.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/.../ShowProcessListDispatchEventBuilder.java → .../ShowProcessListDispatchEventBuilder.java b/.../ShowProcessListDispatchEventBuilder.java → .../ShowProcessListDispatchEventBuilder.java
@@ -15,14 +15,15 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
 import org.apache.shardingsphere.mode.event.DataChangedEvent;
 import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;
 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.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...sphere/mode/manager/cluster/event/dispatch/listener/DataChangedEventListenerRegistry.java b/...sphere/mode/manager/cluster/event/dispatch/listener/DataChangedEventListenerRegistry.java
@@ -22,6 +22,8 @@
 import org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode;
 import org.apache.shardingsphere.mode.manager.ContextManager;
 import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.type.DatabaseMetaDataChangedListener;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.type.GlobalMetaDataChangedListener;
 import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
 
 import java.util.Collection;

diff --git a/...ener/DatabaseMetaDataChangedListener.java → ...type/DatabaseMetaDataChangedListener.java b/...ener/DatabaseMetaDataChangedListener.java → ...type/DatabaseMetaDataChangedListener.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.type;
 
 import com.google.common.base.Preconditions;
 import lombok.RequiredArgsConstructor;

diff --git a/...stener/GlobalMetaDataChangedListener.java → ...r/type/GlobalMetaDataChangedListener.java b/...stener/GlobalMetaDataChangedListener.java → ...r/type/GlobalMetaDataChangedListener.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.type;
 
 import lombok.RequiredArgsConstructor;
 import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;

diff --git a/...ode/manager/cluster/event/dispatch/subscriber/ClusterDispatchEventSubscriberRegistry.java b/...ode/manager/cluster/event/dispatch/subscriber/ClusterDispatchEventSubscriberRegistry.java
@@ -20,6 +20,18 @@
 import lombok.Getter;
 import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
 import org.apache.shardingsphere.mode.manager.ContextManager;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.CacheEvictedSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.ComputeNodeStateSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.DatabaseDataChangedSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.GlobalRuleConfigurationEventSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.ListenerAssistedSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.MetaDataChangedSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.ProcessListChangedSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.PropertiesEventSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.QualifiedDataSourceSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.RuleItemChangedSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.StateChangedSubscriber;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type.StorageUnitEventSubscriber;
 
 import java.util.Arrays;
 import java.util.Collection;

diff --git a/...ch/subscriber/CacheEvictedSubscriber.java → ...bscriber/type/CacheEvictedSubscriber.java b/...ch/subscriber/CacheEvictedSubscriber.java → ...bscriber/type/CacheEvictedSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;

diff --git a/...ubscriber/ComputeNodeStateSubscriber.java → ...iber/type/ComputeNodeStateSubscriber.java b/...ubscriber/ComputeNodeStateSubscriber.java → ...iber/type/ComputeNodeStateSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import lombok.RequiredArgsConstructor;

diff --git a/...criber/DatabaseDataChangedSubscriber.java → ...r/type/DatabaseDataChangedSubscriber.java b/...criber/DatabaseDataChangedSubscriber.java → ...r/type/DatabaseDataChangedSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import lombok.RequiredArgsConstructor;

diff --git a/...obalRuleConfigurationEventSubscriber.java → ...obalRuleConfigurationEventSubscriber.java b/...obalRuleConfigurationEventSubscriber.java → ...obalRuleConfigurationEventSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.base.Preconditions;
 import com.google.common.eventbus.Subscribe;

diff --git a/...ubscriber/ListenerAssistedSubscriber.java → ...iber/type/ListenerAssistedSubscriber.java b/...ubscriber/ListenerAssistedSubscriber.java → ...iber/type/ListenerAssistedSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import lombok.RequiredArgsConstructor;
@@ -26,7 +26,7 @@
 import org.apache.shardingsphere.mode.event.dispatch.assisted.DropDatabaseListenerAssistedEvent;
 import org.apache.shardingsphere.mode.lock.GlobalLockContext;
 import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.DatabaseMetaDataChangedListener;
+import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.type.DatabaseMetaDataChangedListener;
 import org.apache.shardingsphere.mode.manager.cluster.persist.service.GlobalLockPersistService;
 import org.apache.shardingsphere.mode.metadata.refresher.ShardingSphereStatisticsRefreshEngine;
 import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;

diff --git a/...subscriber/MetaDataChangedSubscriber.java → ...riber/type/MetaDataChangedSubscriber.java b/...subscriber/MetaDataChangedSubscriber.java → ...riber/type/MetaDataChangedSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.base.Preconditions;
 import com.google.common.eventbus.Subscribe;

diff --git a/...scriber/ProcessListChangedSubscriber.java → ...er/type/ProcessListChangedSubscriber.java b/...scriber/ProcessListChangedSubscriber.java → ...er/type/ProcessListChangedSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import lombok.RequiredArgsConstructor;

diff --git a/...subscriber/PropertiesEventSubscriber.java → ...riber/type/PropertiesEventSubscriber.java b/...subscriber/PropertiesEventSubscriber.java → ...riber/type/PropertiesEventSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.base.Preconditions;
 import com.google.common.eventbus.Subscribe;

diff --git a/...criber/QualifiedDataSourceSubscriber.java → ...r/type/QualifiedDataSourceSubscriber.java b/...criber/QualifiedDataSourceSubscriber.java → ...r/type/QualifiedDataSourceSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.base.Preconditions;
 import com.google.common.eventbus.Subscribe;

diff --git a/...subscriber/RuleItemChangedSubscriber.java → ...riber/type/RuleItemChangedSubscriber.java b/...subscriber/RuleItemChangedSubscriber.java → ...riber/type/RuleItemChangedSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import lombok.RequiredArgsConstructor;

diff --git a/...ch/subscriber/StateChangedSubscriber.java → ...bscriber/type/StateChangedSubscriber.java b/...ch/subscriber/StateChangedSubscriber.java → ...bscriber/type/StateChangedSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.eventbus.Subscribe;
 import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;

diff --git a/...ubscriber/StorageUnitEventSubscriber.java → ...iber/type/StorageUnitEventSubscriber.java b/...ubscriber/StorageUnitEventSubscriber.java → ...iber/type/StorageUnitEventSubscriber.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.type;
 
 import com.google.common.base.Preconditions;
 import com.google.common.eventbus.Subscribe;

diff --git a/...rg.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder b/...rg.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder
@@ -15,13 +15,13 @@
 # limitations under the License.
 #
 
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.QualifiedDataSourceDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.ComputeNodeStateDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.ClusterStateDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.ShardingSphereDataDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.GlobalRuleDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.PropertiesDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.ListenerAssistedDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.ComputeNodeOnlineDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.ShowProcessListDispatchEventBuilder
-org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.KillProcessDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.QualifiedDataSourceDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.ComputeNodeStateDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.ClusterStateDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.ShardingSphereDataDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.GlobalRuleDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.PropertiesDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.ListenerAssistedDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.ComputeNodeOnlineDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.ShowProcessListDispatchEventBuilder
+org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type.KillProcessDispatchEventBuilder
diff --git a/...verQualifiedDataSourceSubscriberTest.java → ...verQualifiedDataSourceSubscriberTest.java b/...verQualifiedDataSourceSubscriberTest.java → ...verQualifiedDataSourceSubscriberTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber;
+package org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber.type;
 
 import org.apache.shardingsphere.infra.metadata.database.schema.QualifiedDataSource;
 import org.apache.shardingsphere.mode.event.deliver.datasource.qualified.QualifiedDataSourceDeletedEvent;

diff --git a/...ClusterStateDispatchEventBuilderTest.java → ...ClusterStateDispatchEventBuilderTest.java b/...ClusterStateDispatchEventBuilderTest.java → ...ClusterStateDispatchEventBuilderTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import org.apache.shardingsphere.infra.state.cluster.ClusterState;
 import org.apache.shardingsphere.mode.event.DataChangedEvent;

diff --git a/...teNodeOnlineDispatchEventBuilderTest.java → ...teNodeOnlineDispatchEventBuilderTest.java b/...teNodeOnlineDispatchEventBuilderTest.java → ...teNodeOnlineDispatchEventBuilderTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;
+package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.type;
 
 import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
 import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;