| Package | Description |
|---|---|
| com.mysql.cj.protocol | |
| com.mysql.cj.protocol.a | |
| com.mysql.cj.protocol.x |
| Modifier and Type | Method and Description |
|---|---|
default MessageReader<H,M> |
MessageReader.undecorate()
Return the previous MessageReader instance from the decorators chain or the current MessageReader
if it is the first entry in a chain.
|
default MessageReader<H,M> |
MessageReader.undecorateAll()
Return a MessageReader instance free of decorators.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DebugBufferingPacketReader
A decorating
MessageReader which put debugging info to a ring-buffer. |
class |
MultiPacketReader
A
MessageReader which reads a full packet
built from sequence of it's on-wire parts. |
class |
SimplePacketReader
Simple implementation of
MessageReader which handles the receiving of logical MySQL packets from the provided socket input stream. |
class |
TimeTrackingPacketReader
A
MessageReader which tracks the last time a packet was received. |
class |
TracingPacketReader
A decorating
MessageReader which traces all received packets to the provided logger. |
| Modifier and Type | Field and Description |
|---|---|
private MessageReader<NativePacketHeader,NativePacketPayload> |
TimeTrackingPacketReader.packetReader |
private MessageReader<NativePacketHeader,NativePacketPayload> |
DebugBufferingPacketReader.packetReader |
protected MessageReader<NativePacketHeader,NativePacketPayload> |
NativeProtocol.packetReader |
private MessageReader<NativePacketHeader,NativePacketPayload> |
TracingPacketReader.packetReader |
private MessageReader<NativePacketHeader,NativePacketPayload> |
MultiPacketReader.packetReader |
| Modifier and Type | Method and Description |
|---|---|
MessageReader<NativePacketHeader,NativePacketPayload> |
NativeProtocol.getPacketReader() |
MessageReader<NativePacketHeader,NativePacketPayload> |
TimeTrackingPacketReader.undecorate() |
MessageReader<NativePacketHeader,NativePacketPayload> |
DebugBufferingPacketReader.undecorate() |
MessageReader<NativePacketHeader,NativePacketPayload> |
TracingPacketReader.undecorate() |
MessageReader<NativePacketHeader,NativePacketPayload> |
MultiPacketReader.undecorate() |
MessageReader<NativePacketHeader,NativePacketPayload> |
TimeTrackingPacketReader.undecorateAll() |
MessageReader<NativePacketHeader,NativePacketPayload> |
DebugBufferingPacketReader.undecorateAll() |
MessageReader<NativePacketHeader,NativePacketPayload> |
TracingPacketReader.undecorateAll() |
MessageReader<NativePacketHeader,NativePacketPayload> |
MultiPacketReader.undecorateAll() |
| Modifier and Type | Method and Description |
|---|---|
void |
NativeProtocol.applyPacketDecorators(MessageSender<NativePacketPayload> sender,
MessageReader<NativePacketHeader,NativePacketPayload> messageReader)
Apply optional decorators to configured PacketSender and PacketReader.
|
| Constructor and Description |
|---|
DebugBufferingPacketReader(MessageReader<NativePacketHeader,NativePacketPayload> packetReader,
java.util.LinkedList<java.lang.StringBuilder> packetDebugBuffer,
RuntimeProperty<java.lang.Integer> packetDebugBufferSize) |
MultiPacketReader(MessageReader<NativePacketHeader,NativePacketPayload> packetReader) |
TimeTrackingPacketReader(MessageReader<NativePacketHeader,NativePacketPayload> messageReader) |
TracingPacketReader(MessageReader<NativePacketHeader,NativePacketPayload> packetReader,
Log log) |
| Modifier and Type | Class and Description |
|---|---|
class |
SyncMessageReader
Synchronous-only implementation of
MessageReader. |
| Modifier and Type | Field and Description |
|---|---|
private MessageReader<XMessageHeader,XMessage> |
XProtocol.reader |