io.shardingsphere.proxy.transport.common.codec

Class PacketCodec<T extends DatabaseProtocolPacket>

java.lang.Object

<any>

io.shardingsphere.proxy.transport.common.codec.PacketCodec<T>

Direct Known Subclasses:

MySQLPacketCodec

public abstract class PacketCodec<T extends DatabaseProtocolPacket>
extends <any>

Database protocol packet codec.

Author:

zhangliang

Constructor Summary

Constructors

Constructor and Description
PacketCodec()

Method Summary

Modifier and Type	Method and Description
protected void	decode(ChannelHandlerContext context, ByteBuf in, List<Object> out)
protected abstract void	doDecode(ChannelHandlerContext context, ByteBuf in, List<Object> out, int readableBytes)
protected abstract void	doEncode(ChannelHandlerContext context, T message, ByteBuf out)
protected void	encode(ChannelHandlerContext context, T message, ByteBuf out)
protected abstract boolean	isValidHeader(int readableBytes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PacketCodec

public PacketCodec()

Method Detail

decode

protected void decode(ChannelHandlerContext context,
                      ByteBuf in,
                      List<Object> out)

isValidHeader

protected abstract boolean isValidHeader(int readableBytes)

doDecode

protected abstract void doDecode(ChannelHandlerContext context,
                                 ByteBuf in,
                                 List<Object> out,
                                 int readableBytes)

encode

protected void encode(ChannelHandlerContext context,
                      T message,
                      ByteBuf out)

doEncode

protected abstract void doEncode(ChannelHandlerContext context,
                                 T message,
                                 ByteBuf out)