Skip to content

Commit

Permalink
Adjust package of cluster-mode-core module
Browse files Browse the repository at this point in the history
  • Loading branch information
@terrymanu
terrymanu committed Dec 12, 2024
1 parent f3a25c3 commit 173d865
Show file tree
Hide file tree
Showing 58 changed files with 89 additions and 102 deletions.
6 changes: 3 additions & 3 deletions ...ain/java/org/apache/shardingsphere/mode/manager/cluster/ClusterContextManagerBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,10 +31,10 @@
import org.apache.shardingsphere.mode.manager.ContextManager;
import org.apache.shardingsphere.mode.manager.ContextManagerBuilder;
import org.apache.shardingsphere.mode.manager.ContextManagerBuilderParameter;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.registry.ClusterDeliverEventSubscriberRegistry;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.registry.ClusterDispatchEventSubscriberRegistry;
import org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber.ClusterDeliverEventSubscriberRegistry;
import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber.ClusterDispatchEventSubscriberRegistry;
import org.apache.shardingsphere.mode.manager.cluster.exception.MissingRequiredClusterRepositoryConfigurationException;
import org.apache.shardingsphere.mode.manager.cluster.listener.DataChangedEventListenerRegistry;
import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.DataChangedEventListenerRegistry;
import org.apache.shardingsphere.mode.manager.cluster.persist.GlobalLockPersistService;
import org.apache.shardingsphere.mode.manager.cluster.workerid.ClusterWorkerIdGenerator;
import org.apache.shardingsphere.mode.metadata.MetaDataContexts;
Expand Down
3 changes: 1 addition & 2 deletions ...lusterDeliverEventSubscriberRegistry.java → ...lusterDeliverEventSubscriberRegistry.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,11 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.registry;
package org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber;

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.subscriber.deliver.DeliverQualifiedDataSourceSubscriber;
import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;

import java.util.Collection;
Expand Down
2 changes: 1 addition & 1 deletion ...DeliverQualifiedDataSourceSubscriber.java → ...DeliverQualifiedDataSourceSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.deliver;
package org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber;

import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
Expand Down
2 changes: 1 addition & 1 deletion ...der/ClusterStateDispatchEventBuilder.java → ...der/ClusterStateDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.infra.state.cluster.ClusterState;
import org.apache.shardingsphere.metadata.persist.node.StatesNode;
Expand Down
2 changes: 1 addition & 1 deletion ...omputeNodeOnlineDispatchEventBuilder.java → ...omputeNodeOnlineDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.infra.instance.ComputeNodeData;
import org.apache.shardingsphere.infra.instance.metadata.InstanceMetaData;
Expand Down
2 changes: 1 addition & 1 deletion ...ComputeNodeStateDispatchEventBuilder.java → ...ComputeNodeStateDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import com.google.common.base.Strings;
import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
Expand Down
2 changes: 1 addition & 1 deletion ...r/event/builder/DispatchEventBuilder.java → ...ispatch/builder/DispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.infra.spi.annotation.SingletonSPI;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...ilder/GlobalRuleDispatchEventBuilder.java → ...ilder/GlobalRuleDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.metadata.persist.node.GlobalNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...lder/KillProcessDispatchEventBuilder.java → ...lder/KillProcessDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...ListenerAssistedDispatchEventBuilder.java → ...ListenerAssistedDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
import org.apache.shardingsphere.metadata.persist.node.StatesNode;
Expand Down
2 changes: 1 addition & 1 deletion ...ilder/PropertiesDispatchEventBuilder.java → ...ilder/PropertiesDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.metadata.persist.node.GlobalNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...lifiedDataSourceDispatchEventBuilder.java → ...lifiedDataSourceDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import com.google.common.base.Strings;
import org.apache.shardingsphere.infra.metadata.database.schema.QualifiedDataSource;
Expand Down
2 changes: 1 addition & 1 deletion ...ardingSphereDataDispatchEventBuilder.java → ...ardingSphereDataDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import com.google.common.base.Strings;
import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
Expand Down
2 changes: 1 addition & 1 deletion .../ShowProcessListDispatchEventBuilder.java → .../ShowProcessListDispatchEventBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
4 changes: 2 additions & 2 deletions ...ner/DataChangedEventListenerRegistry.java → ...ner/DataChangedEventListenerRegistry.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,13 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.listener;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener;

import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode;
import org.apache.shardingsphere.mode.manager.ContextManager;
import org.apache.shardingsphere.mode.manager.cluster.event.builder.DispatchEventBuilder;
import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;

import java.util.Collection;
Expand Down
2 changes: 1 addition & 1 deletion ...ener/DatabaseMetaDataChangedListener.java → ...ener/DatabaseMetaDataChangedListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.listener;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener;

import com.google.common.base.Preconditions;
import lombok.RequiredArgsConstructor;
Expand Down
4 changes: 2 additions & 2 deletions ...stener/GlobalMetaDataChangedListener.java → ...stener/GlobalMetaDataChangedListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,12 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.listener;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener;

import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.manager.cluster.event.builder.DispatchEventBuilder;
import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder;
import org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener;

/**
Expand Down
2 changes: 1 addition & 1 deletion ...iber/dispatch/CacheEvictedSubscriber.java → ...ch/subscriber/CacheEvictedSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.eventbus.Subscribe;
import org.apache.shardingsphere.mode.event.dispatch.DispatchEvent;
Expand Down
14 changes: 1 addition & 13 deletions ...usterDispatchEventSubscriberRegistry.java → ...usterDispatchEventSubscriberRegistry.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,23 +15,11 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.registry;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

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.subscriber.dispatch.CacheEvictedSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.ComputeNodeStateSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.DatabaseDataChangedSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.GlobalRuleConfigurationEventSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.ListenerAssistedSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.ProcessListChangedSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.PropertiesEventSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.QualifiedDataSourceSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.MetaDataChangedSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.RuleItemChangedSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.StateChangedSubscriber;
import org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch.StorageUnitEventSubscriber;

import java.util.Arrays;
import java.util.Collection;
Expand Down
2 changes: 1 addition & 1 deletion .../dispatch/ComputeNodeStateSubscriber.java → ...ubscriber/ComputeNodeStateSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
Expand Down
2 changes: 1 addition & 1 deletion ...spatch/DatabaseDataChangedSubscriber.java → ...criber/DatabaseDataChangedSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
Expand Down
2 changes: 1 addition & 1 deletion ...obalRuleConfigurationEventSubscriber.java → ...obalRuleConfigurationEventSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.base.Preconditions;
import com.google.common.eventbus.Subscribe;
Expand Down
4 changes: 2 additions & 2 deletions .../dispatch/ListenerAssistedSubscriber.java → ...ubscriber/ListenerAssistedSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
Expand All @@ -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.listener.DatabaseMetaDataChangedListener;
import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener.DatabaseMetaDataChangedListener;
import org.apache.shardingsphere.mode.manager.cluster.persist.GlobalLockPersistService;
import org.apache.shardingsphere.mode.metadata.refresher.ShardingSphereStatisticsRefreshEngine;
import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
Expand Down
2 changes: 1 addition & 1 deletion ...r/dispatch/MetaDataChangedSubscriber.java → ...subscriber/MetaDataChangedSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.base.Preconditions;
import com.google.common.eventbus.Subscribe;
Expand Down
2 changes: 1 addition & 1 deletion ...ispatch/ProcessListChangedSubscriber.java → ...scriber/ProcessListChangedSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
Expand Down
2 changes: 1 addition & 1 deletion ...r/dispatch/PropertiesEventSubscriber.java → ...subscriber/PropertiesEventSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.base.Preconditions;
import com.google.common.eventbus.Subscribe;
Expand Down
2 changes: 1 addition & 1 deletion ...spatch/QualifiedDataSourceSubscriber.java → ...criber/QualifiedDataSourceSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.base.Preconditions;
import com.google.common.eventbus.Subscribe;
Expand Down
2 changes: 1 addition & 1 deletion ...r/dispatch/RuleItemChangedSubscriber.java → ...subscriber/RuleItemChangedSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.eventbus.Subscribe;
import lombok.RequiredArgsConstructor;
Expand Down
2 changes: 1 addition & 1 deletion ...iber/dispatch/StateChangedSubscriber.java → ...ch/subscriber/StateChangedSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.eventbus.Subscribe;
import org.apache.shardingsphere.infra.util.eventbus.EventSubscriber;
Expand Down
2 changes: 1 addition & 1 deletion .../dispatch/StorageUnitEventSubscriber.java → ...ubscriber/StorageUnitEventSubscriber.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.dispatch;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.subscriber;

import com.google.common.base.Preconditions;
import com.google.common.eventbus.Subscribe;
Expand Down
27 changes: 0 additions & 27 deletions ...ervices/org.apache.shardingsphere.mode.manager.cluster.event.builder.DispatchEventBuilder
View file

This file was deleted.

27 changes: 27 additions & 0 deletions ...rg.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder.DispatchEventBuilder
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# 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
2 changes: 1 addition & 1 deletion ...verQualifiedDataSourceSubscriberTest.java → ...verQualifiedDataSourceSubscriberTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.subscriber.deliver;
package org.apache.shardingsphere.mode.manager.cluster.event.deliver.subscriber;

import org.apache.shardingsphere.infra.metadata.database.schema.QualifiedDataSource;
import org.apache.shardingsphere.mode.event.deliver.datasource.qualified.QualifiedDataSourceDeletedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...ClusterStateDispatchEventBuilderTest.java → ...ClusterStateDispatchEventBuilderTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.event.builder;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.builder;

import org.apache.shardingsphere.infra.state.cluster.ClusterState;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
Loading

0 comments on commit 173d865

Please sign in to comment.