Skip to content

Commit

Permalink
Add event.dispatch.handler.global package
Browse files Browse the repository at this point in the history
  • Loading branch information
@terrymanu
terrymanu committed Jan 1, 2025
1 parent 9938d48 commit dcb7792
Show file tree
Hide file tree
Showing 21 changed files with 30 additions and 30 deletions.
2 changes: 1 addition & 1 deletion ...dler/type/ClusterStateChangedHandler.java → ...er/global/ClusterStateChangedHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.metadata.persist.node.StatesNode;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...andler/type/ComputeNodeOnlineHandler.java → ...dler/global/ComputeNodeOnlineHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.instance.ComputeNodeData;
import org.apache.shardingsphere.infra.instance.ComputeNodeInstance;
Expand Down
2 changes: 1 addition & 1 deletion .../type/ComputeNodeStateChangedHandler.java → ...lobal/ComputeNodeStateChangedHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import com.google.common.base.Strings;
import org.apache.shardingsphere.infra.instance.ComputeNodeInstanceContext;
Expand Down
2 changes: 1 addition & 1 deletion ...andler/type/GlobalRuleChangedHandler.java → ...dler/global/GlobalRuleChangedHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import com.google.common.base.Preconditions;
import org.apache.shardingsphere.infra.config.rule.RuleConfiguration;
Expand Down
2 changes: 1 addition & 1 deletion ...atch/handler/type/KillProcessHandler.java → ...ch/handler/global/KillProcessHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.exception.core.external.sql.type.wrapper.SQLWrapperException;
import org.apache.shardingsphere.infra.executor.sql.process.ProcessRegistry;
Expand Down
2 changes: 1 addition & 1 deletion .../type/ListenerAssistedChangedHandler.java → ...lobal/ListenerAssistedChangedHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
import org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode;
Expand Down
2 changes: 1 addition & 1 deletion ...andler/type/PropertiesChangedHandler.java → ...dler/global/PropertiesChangedHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import com.google.common.base.Preconditions;
import org.apache.shardingsphere.metadata.persist.node.GlobalNode;
Expand Down
2 changes: 1 addition & 1 deletion ...pe/QualifiedDataSourceChangedHandler.java → ...al/QualifiedDataSourceChangedHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import com.google.common.base.Preconditions;
import com.google.common.base.Strings;
Expand Down
2 changes: 1 addition & 1 deletion ...ype/ShardingSphereDataChangedHandler.java → ...bal/ShardingSphereDataChangedHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import com.google.common.base.Strings;
import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
Expand Down
2 changes: 1 addition & 1 deletion .../handler/type/ShowProcessListHandler.java → ...andler/global/ShowProcessListHandler.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.executor.sql.process.lock.ProcessOperationLockRegistry;
import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
Expand Down
20 changes: 10 additions & 10 deletions ...apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.DataChangedEventHandler
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,13 @@
# limitations under the License.
#

org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.ClusterStateChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.QualifiedDataSourceChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.ComputeNodeOnlineHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.ComputeNodeStateChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.ShardingSphereDataChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.GlobalRuleChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.PropertiesChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.ListenerAssistedChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.ShowProcessListHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.type.KillProcessHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.ClusterStateChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.QualifiedDataSourceChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.ComputeNodeOnlineHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.ComputeNodeStateChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.ShardingSphereDataChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.GlobalRuleChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.PropertiesChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.ListenerAssistedChangedHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.ShowProcessListHandler
org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global.KillProcessHandler
2 changes: 1 addition & 1 deletion .../type/ClusterStateChangedHandlerTest.java → ...lobal/ClusterStateChangedHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...er/type/ComputeNodeOnlineHandlerTest.java → .../global/ComputeNodeOnlineHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.instance.ComputeNodeInstance;
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
Expand Down
2 changes: 1 addition & 1 deletion ...e/ComputeNodeStateChangedHandlerTest.java → ...l/ComputeNodeStateChangedHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...er/type/GlobalRuleChangedHandlerTest.java → .../global/GlobalRuleChangedHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.config.rule.RuleConfiguration;
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
Expand Down
2 changes: 1 addition & 1 deletion .../handler/type/KillProcessHandlerTest.java → ...andler/global/KillProcessHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.executor.sql.process.lock.ProcessOperationLockRegistry;
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
Expand Down
2 changes: 1 addition & 1 deletion ...e/ListenerAssistedChangedHandlerTest.java → ...l/ListenerAssistedChangedHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.config.props.temporary.TemporaryConfigurationProperties;
import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
Expand Down
2 changes: 1 addition & 1 deletion ...er/type/PropertiesChangedHandlerTest.java → .../global/PropertiesChangedHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
Expand Down
2 changes: 1 addition & 1 deletion ...ualifiedDataSourceChangedHandlerTest.java → ...ualifiedDataSourceChangedHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.metadata.database.schema.QualifiedDataSource;
import org.apache.shardingsphere.infra.rule.attribute.datasource.StaticDataSourceRuleAttribute;
Expand Down
2 changes: 1 addition & 1 deletion ...ShardingSphereDataChangedHandlerTest.java → ...ShardingSphereDataChangedHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.infra.yaml.data.pojo.YamlShardingSphereRowData;
Expand Down
2 changes: 1 addition & 1 deletion ...dler/type/ShowProcessListHandlerTest.java → ...er/global/ShowProcessListHandlerTest.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.dispatch.handler.type;
package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.global;

import org.apache.shardingsphere.infra.executor.sql.process.ProcessRegistry;
import org.apache.shardingsphere.infra.executor.sql.process.lock.ProcessOperationLockRegistry;
Expand Down

0 comments on commit dcb7792

Please sign in to comment.