diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/listener/CreateDatabaseListenerAssistedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/assisted/CreateDatabaseListenerAssistedEvent.java similarity index 93% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/listener/CreateDatabaseListenerAssistedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/assisted/CreateDatabaseListenerAssistedEvent.java index 05094eab17776..757683437fac8 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/listener/CreateDatabaseListenerAssistedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/assisted/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/listener/DropDatabaseListenerAssistedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/assisted/DropDatabaseListenerAssistedEvent.java similarity index 93% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/listener/DropDatabaseListenerAssistedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/assisted/DropDatabaseListenerAssistedEvent.java index e6d8bd945183d..764745dd15caf 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/listener/DropDatabaseListenerAssistedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/assisted/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/DatabaseDataAddedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/DatabaseDataAddedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/DatabaseDataAddedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/DatabaseDataAddedEvent.java index f9ff3137c83af..a1a39165fbfd0 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/DatabaseDataAddedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/DatabaseDataDeletedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/DatabaseDataDeletedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/DatabaseDataDeletedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/DatabaseDataDeletedEvent.java index 2d0f9b218742c..601f0db2c0001 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/DatabaseDataDeletedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/SchemaDataAddedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/SchemaDataAddedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/SchemaDataAddedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/SchemaDataAddedEvent.java index 429193f59e9cc..5ec43c3736226 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/SchemaDataAddedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/SchemaDataDeletedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/SchemaDataDeletedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/SchemaDataDeletedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/SchemaDataDeletedEvent.java index 6e651136bf707..a493f1d98fa4c 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/SchemaDataDeletedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/ShardingSphereRowDataChangedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/ShardingSphereRowDataChangedEvent.java similarity index 93% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/ShardingSphereRowDataChangedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/ShardingSphereRowDataChangedEvent.java index fd6b8512c7303..2053def51abff 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/ShardingSphereRowDataChangedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/ShardingSphereRowDataDeletedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/ShardingSphereRowDataDeletedEvent.java similarity index 93% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/ShardingSphereRowDataDeletedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/ShardingSphereRowDataDeletedEvent.java index 448ec056e7f36..74b96a2d3559a 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/ShardingSphereRowDataDeletedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/TableDataChangedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/TableDataChangedEvent.java similarity index 93% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/TableDataChangedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/data/TableDataChangedEvent.java index 42a39953f0886..e55c76e62c447 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/data/event/TableDataChangedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/event/SchemaAddedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/SchemaAddedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/event/SchemaAddedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/SchemaAddedEvent.java index 9b21fe77312e9..21a35085b65b6 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/event/SchemaAddedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/event/SchemaDeletedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/SchemaDeletedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/event/SchemaDeletedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/SchemaDeletedEvent.java index ec6493f0edebb..dd6b0684f97fd 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/event/SchemaDeletedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/table/CreateOrAlterTableEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/table/CreateOrAlterTableEvent.java similarity index 94% rename from mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/table/CreateOrAlterTableEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/table/CreateOrAlterTableEvent.java index 51a62f0b4cf80..e87271cdff966 100644 --- a/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/table/CreateOrAlterTableEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/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/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/table/DropTableEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/table/DropTableEvent.java similarity index 93% rename from mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/table/DropTableEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/table/DropTableEvent.java index 3b819fb166e7f..24cbdf861fcf0 100644 --- a/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/table/DropTableEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/view/CreateOrAlterViewEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/view/CreateOrAlterViewEvent.java similarity index 94% rename from mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/view/CreateOrAlterViewEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/view/CreateOrAlterViewEvent.java index 2bebe029b41b6..481e5f1d4c795 100644 --- a/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/view/CreateOrAlterViewEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/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/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/view/DropViewEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/view/DropViewEvent.java similarity index 94% rename from mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/view/DropViewEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/metadata/schema/view/DropViewEvent.java index f8f097ae206ed..ecb83629674c5 100644 --- a/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/schema/view/DropViewEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/cluster/event/ClusterStateEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/cluster/ClusterStateEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/cluster/event/ClusterStateEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/cluster/ClusterStateEvent.java index 1518da048a4e1..2919c235068c7 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/cluster/event/ClusterStateEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ComputeNodeInstanceStateChangedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/ComputeNodeInstanceStateChangedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ComputeNodeInstanceStateChangedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/ComputeNodeInstanceStateChangedEvent.java index 6a6d86ca09460..3e5ccdc630510 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ComputeNodeInstanceStateChangedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/KillLocalProcessCompletedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/KillLocalProcessCompletedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/KillLocalProcessCompletedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/KillLocalProcessCompletedEvent.java index bbe170c49ac5a..b3b90f2a8a1c5 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/KillLocalProcessCompletedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/KillLocalProcessEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/KillLocalProcessEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/KillLocalProcessEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/KillLocalProcessEvent.java index 201e30f07252d..f49961888dc9e 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/KillLocalProcessEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/LabelsEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/LabelsEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/LabelsEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/LabelsEvent.java index 878f3e90111c7..b0436286d9d31 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/LabelsEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ReportLocalProcessesCompletedEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/ReportLocalProcessesCompletedEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ReportLocalProcessesCompletedEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/ReportLocalProcessesCompletedEvent.java index 3346ba8f68a52..df1dfc4044f0b 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ReportLocalProcessesCompletedEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ReportLocalProcessesEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/ReportLocalProcessesEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ReportLocalProcessesEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/ReportLocalProcessesEvent.java index 492e61e67ba8a..a0f6250db54dc 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/ReportLocalProcessesEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/WorkerIdEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/WorkerIdEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/WorkerIdEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/WorkerIdEvent.java index 4c0b145dfa7b4..3c41a320a3cb8 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/event/WorkerIdEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/event/InstanceOfflineEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/instance/InstanceOfflineEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/event/InstanceOfflineEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/instance/InstanceOfflineEvent.java index 466cdce98d0cc..9c20d07592f02 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/event/InstanceOfflineEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/event/InstanceOnlineEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/instance/InstanceOnlineEvent.java similarity index 92% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/event/InstanceOnlineEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/compute/instance/InstanceOnlineEvent.java index 5e58c81237e24..a7016401c7d4b 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/compute/online/event/InstanceOnlineEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/storage/event/QualifiedDataSourceStateEvent.java b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/storage/QualifiedDataSourceStateEvent.java similarity index 93% rename from mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/storage/event/QualifiedDataSourceStateEvent.java rename to mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/storage/QualifiedDataSourceStateEvent.java index 7c82381e3a2fe..fcd1b417c1ad5 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/nodes/storage/event/QualifiedDataSourceStateEvent.java +++ b/mode/api/src/main/java/org/apache/shardingsphere/mode/event/dispatch/state/storage/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/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 93fef6f57f2bf..e555fd95f9834 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 @@ -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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/processor/CreateDatabaseListenerAssistedProcessor.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/processor/CreateDatabaseListenerAssistedProcessor.java index 502b855f7d4cd..cd8f87e23d6f2 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/processor/CreateDatabaseListenerAssistedProcessor.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/processor/DropDatabaseListenerAssistedProcessor.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/processor/DropDatabaseListenerAssistedProcessor.java index 8ce840e4a8bdc..4c0f10525d1df 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/listener/processor/DropDatabaseListenerAssistedProcessor.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java index ef94a58464e5b..b48c7567db163 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilder.java +++ b/mode/type/cluster/core/src/main/java/org/apache/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilder.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilder.java index 8da0cde9bcfae..312541d2a6eb7 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilder.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilder.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilder.java index f773a8c1ac908..f26a50a0ed5a9 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilder.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ListenerAssistedDispatchEventBuilder.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ListenerAssistedDispatchEventBuilder.java index 5610d73018ab2..bf0ad274036fa 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ListenerAssistedDispatchEventBuilder.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilder.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilder.java index 19d94617f7c73..f402a5c682428 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilder.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ShardingSphereDataDispatchEventBuilder.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ShardingSphereDataDispatchEventBuilder.java index 24baaba804f83..3864ecc2d70d0 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ShardingSphereDataDispatchEventBuilder.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriber.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriber.java index 2699eb378fcf0..653d6ad163450 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriber.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/DatabaseChangedSubscriber.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/DatabaseChangedSubscriber.java index 13246e2fb4adf..e952480bc3459 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/DatabaseChangedSubscriber.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/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/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ListenerAssistedMetaDataChangedSubscriber.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ListenerAssistedMetaDataChangedSubscriber.java index 3406be5244483..a192a8135556b 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ListenerAssistedMetaDataChangedSubscriber.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/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; diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriber.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriber.java index 5c47c479b97f7..c3ef631a0d961 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriber.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriber.java @@ -28,10 +28,10 @@ import org.apache.shardingsphere.metadata.persist.node.ComputeNode; import org.apache.shardingsphere.metadata.persist.node.ProcessNode; import org.apache.shardingsphere.mode.manager.ContextManager; -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.ReportLocalProcessesCompletedEvent; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.ReportLocalProcessesEvent; +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.ReportLocalProcessesCompletedEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.compute.ReportLocalProcessesEvent; import java.sql.SQLException; import java.sql.Statement; diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriber.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriber.java index 634679a801c75..51bde5900a2f7 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriber.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriber.java @@ -24,7 +24,7 @@ import org.apache.shardingsphere.infra.rule.attribute.datasource.StaticDataSourceRuleAttribute; 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.storage.event.QualifiedDataSourceStateEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.storage.QualifiedDataSourceStateEvent; /** * Qualified data source subscriber. diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriber.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriber.java index 62ac76cb60c78..17c92504be8b9 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriber.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriber.java @@ -22,13 +22,13 @@ import org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable; import org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereView; import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber; -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.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.manager.ContextManager; -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.SchemaAddedEvent; +import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.SchemaDeletedEvent; import java.util.Map; diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriber.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriber.java index d20d19985afc7..719bd65d1b18b 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriber.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriber.java @@ -20,10 +20,10 @@ import com.google.common.eventbus.Subscribe; import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber; import org.apache.shardingsphere.mode.manager.ContextManager; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.event.ClusterStateEvent; -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.LabelsEvent; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.WorkerIdEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.cluster.ClusterStateEvent; +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; /** * State changed subscriber. diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilderTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilderTest.java index 366349342db1f..b70c8c823588d 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilderTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ClusterStateDispatchEventBuilderTest.java @@ -19,7 +19,7 @@ import org.apache.shardingsphere.infra.state.cluster.ClusterState; import org.apache.shardingsphere.infra.rule.event.GovernanceEvent; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.event.ClusterStateEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.cluster.ClusterStateEvent; import org.apache.shardingsphere.mode.event.DataChangedEvent; import org.apache.shardingsphere.mode.event.DataChangedEvent.Type; import org.junit.jupiter.api.Test; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilderTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilderTest.java index b89a7c54ee463..d8202653352e9 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilderTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeOnlineDispatchEventBuilderTest.java @@ -21,8 +21,8 @@ import org.apache.shardingsphere.infra.rule.event.GovernanceEvent; import org.apache.shardingsphere.mode.event.DataChangedEvent; import org.apache.shardingsphere.mode.event.DataChangedEvent.Type; -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 org.junit.jupiter.api.Test; import java.util.Optional; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilderTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilderTest.java index d8593745996a2..1f75ee2090fb4 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilderTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/ComputeNodeStateDispatchEventBuilderTest.java @@ -20,8 +20,8 @@ import org.apache.shardingsphere.infra.state.instance.InstanceState; import org.apache.shardingsphere.infra.util.yaml.YamlEngine; import org.apache.shardingsphere.infra.rule.event.GovernanceEvent; -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.ComputeNodeInstanceStateChangedEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.compute.LabelsEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.compute.ComputeNodeInstanceStateChangedEvent; import org.apache.shardingsphere.mode.event.DataChangedEvent; import org.apache.shardingsphere.mode.event.DataChangedEvent.Type; import org.junit.jupiter.api.Test; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilderTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilderTest.java index d5dd87d70cfa1..1ce2262fc8c18 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilderTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilderTest.java @@ -21,7 +21,7 @@ import org.apache.shardingsphere.infra.state.datasource.DataSourceState; import org.apache.shardingsphere.mode.event.DataChangedEvent; import org.apache.shardingsphere.mode.event.DataChangedEvent.Type; -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.junit.jupiter.api.Test; import java.util.Optional; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/CacheEvictedSubscriberTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/CacheEvictedSubscriberTest.java index e02c44bcc097b..b81437212b330 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/CacheEvictedSubscriberTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/CacheEvictedSubscriberTest.java @@ -19,7 +19,7 @@ import org.apache.shardingsphere.infra.util.eventbus.EventBusContext; import org.apache.shardingsphere.infra.spi.type.ordered.cache.OrderedServicesCache; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.listener.DropDatabaseListenerAssistedEvent; +import org.apache.shardingsphere.mode.event.dispatch.assisted.DropDatabaseListenerAssistedEvent; import org.junit.jupiter.api.Test; import java.util.Collections; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriberTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriberTest.java index 9e6ec4b615b95..bc75bec651b20 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriberTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ComputeNodeOnlineSubscriberTest.java @@ -26,8 +26,8 @@ import org.apache.shardingsphere.mode.manager.ContextManager; import org.apache.shardingsphere.mode.manager.ContextManagerBuilderParameter; import org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder; -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 org.apache.shardingsphere.mode.metadata.MetaDataContextsFactory; import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration; import org.junit.jupiter.api.BeforeEach; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriberTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriberTest.java index e05648fafbe6d..20ffbeb1b9412 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriberTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ProcessListChangedSubscriberTest.java @@ -34,10 +34,10 @@ import org.apache.shardingsphere.mode.manager.ContextManager; import org.apache.shardingsphere.mode.manager.ContextManagerBuilderParameter; import org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder; -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.ReportLocalProcessesCompletedEvent; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.ReportLocalProcessesEvent; +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.ReportLocalProcessesCompletedEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.compute.ReportLocalProcessesEvent; import org.apache.shardingsphere.mode.metadata.MetaDataContextsFactory; import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration; import org.apache.shardingsphere.mode.spi.PersistRepository; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriberTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriberTest.java index 3083d1bcee391..54a0c30bbde28 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriberTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/QualifiedDataSourceSubscriberTest.java @@ -33,7 +33,7 @@ import org.apache.shardingsphere.mode.manager.ContextManager; import org.apache.shardingsphere.mode.manager.ContextManagerBuilderParameter; import org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder; -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.mode.metadata.MetaDataContextsFactory; import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration; import org.apache.shardingsphere.infra.state.datasource.qualified.QualifiedDataSourceState; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriberTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriberTest.java index 252b8c91cc3fc..e102dd0a55323 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriberTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/ResourceMetaDataChangedSubscriberTest.java @@ -30,8 +30,8 @@ import org.apache.shardingsphere.mode.manager.ContextManager; import org.apache.shardingsphere.mode.manager.ContextManagerBuilderParameter; import org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder; -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.SchemaAddedEvent; +import org.apache.shardingsphere.mode.event.dispatch.metadata.schema.SchemaDeletedEvent; import org.apache.shardingsphere.mode.metadata.MetaDataContextsFactory; import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration; import org.junit.jupiter.api.BeforeEach; diff --git a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriberTest.java b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriberTest.java index ba78ea284b5d2..7bdd7454c2f71 100644 --- a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriberTest.java +++ b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/StateChangedSubscriberTest.java @@ -32,10 +32,10 @@ import org.apache.shardingsphere.mode.manager.ContextManager; import org.apache.shardingsphere.mode.manager.ContextManagerBuilderParameter; import org.apache.shardingsphere.mode.manager.cluster.ClusterContextManagerBuilder; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.event.ClusterStateEvent; -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.LabelsEvent; -import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.event.WorkerIdEvent; +import org.apache.shardingsphere.mode.event.dispatch.state.cluster.ClusterStateEvent; +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.metadata.MetaDataContextsFactory; import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration; import org.junit.jupiter.api.BeforeEach;