提交 c894fe58 编写于 作者: T terrymanu

refactor backend.netty's package structure

上级 f51b1c8e
......@@ -34,9 +34,10 @@ import io.shardingsphere.core.routing.router.masterslave.MasterSlaveRouter;
import io.shardingsphere.proxy.backend.AbstractBackendHandler;
import io.shardingsphere.proxy.backend.BackendExecutorContext;
import io.shardingsphere.proxy.backend.ResultPacket;
import io.shardingsphere.proxy.backend.netty.client.BackendNettyClient;
import io.shardingsphere.proxy.backend.netty.future.FutureRegistry;
import io.shardingsphere.proxy.backend.netty.future.SynchronizedFuture;
import io.shardingsphere.proxy.backend.netty.mysql.MySQLQueryResult;
import io.shardingsphere.proxy.backend.netty.client.mysql.MySQLQueryResult;
import io.shardingsphere.proxy.config.ProxyTableMetaDataConnectionManager;
import io.shardingsphere.proxy.config.RuleRegistry;
import io.shardingsphere.proxy.runtime.ChannelRegistry;
......
......@@ -15,7 +15,7 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty;
package io.shardingsphere.proxy.backend.netty.client;
import com.google.common.collect.Maps;
import io.netty.bootstrap.Bootstrap;
......
......@@ -15,7 +15,7 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty;
package io.shardingsphere.proxy.backend.netty.client;
import io.netty.channel.Channel;
import io.netty.channel.ChannelInitializer;
......
......@@ -15,7 +15,7 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty;
package io.shardingsphere.proxy.backend.netty.client;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
......
......@@ -15,7 +15,7 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty;
package io.shardingsphere.proxy.backend.netty.client;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
......
......@@ -15,10 +15,10 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty;
package io.shardingsphere.proxy.backend.netty.client;
import io.shardingsphere.core.constant.DatabaseType;
import io.shardingsphere.proxy.backend.netty.mysql.MySQLBackendHandler;
import io.shardingsphere.proxy.backend.netty.client.mysql.MySQLBackendHandler;
/**
* Backend handler factory for netty.
......
......@@ -15,10 +15,12 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty;
package io.shardingsphere.proxy.backend.netty.client;
import io.netty.channel.Channel;
import io.netty.channel.pool.ChannelPoolHandler;
import io.shardingsphere.proxy.backend.netty.client.BackendNettyClientChannelInitializer;
import io.shardingsphere.proxy.backend.netty.client.DataSourceConfig;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
......
......@@ -15,14 +15,14 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty.mysql;
package io.shardingsphere.proxy.backend.netty.client.mysql;
import com.google.common.collect.Maps;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.shardingsphere.proxy.backend.constant.AuthType;
import io.shardingsphere.proxy.backend.netty.CommandResponsePacketsHandler;
import io.shardingsphere.proxy.backend.netty.DataSourceConfig;
import io.shardingsphere.proxy.backend.netty.client.CommandResponsePacketsHandler;
import io.shardingsphere.proxy.backend.netty.client.DataSourceConfig;
import io.shardingsphere.proxy.runtime.ChannelRegistry;
import io.shardingsphere.proxy.transport.mysql.constant.CapabilityFlag;
import io.shardingsphere.proxy.transport.mysql.constant.PacketHeader;
......
......@@ -15,7 +15,7 @@
* </p>
*/
package io.shardingsphere.proxy.backend.netty.mysql;
package io.shardingsphere.proxy.backend.netty.client.mysql;
import com.google.common.collect.Lists;
import io.shardingsphere.core.merger.QueryResult;
......
......@@ -30,7 +30,7 @@ import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;
import io.shardingsphere.proxy.backend.netty.BackendNettyClient;
import io.shardingsphere.proxy.backend.netty.client.BackendNettyClient;
import io.shardingsphere.proxy.config.RuleRegistry;
import io.shardingsphere.proxy.frontend.common.netty.ServerHandlerInitializer;
import io.shardingsphere.proxy.backend.BackendExecutorContext;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册