| Package | Description |
|---|---|
| com.github.pgasync.impl | |
| com.github.pgasync.impl.io | |
| com.github.pgasync.impl.message | |
| com.github.pgasync.impl.netty |
| Modifier and Type | Method and Description |
|---|---|
void |
PgProtocolStream.send(Message message,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
| Modifier and Type | Method and Description |
|---|---|
void |
PgProtocolStream.connect(StartupMessage startup,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
void |
PgProtocolStream.send(java.util.List<Message> message,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
void |
PgProtocolStream.send(java.util.List<Message> message,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
void |
PgProtocolStream.send(Message message,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
Decoder<T extends Message>
Decoder reads messages from byte buffer.
|
interface |
Encoder<T extends Message>
Encoder writes messages to byte buffer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Authentication |
class |
Bind |
class |
CommandComplete |
class |
DataRow |
class |
ErrorResponse |
class |
ExtendedQuery
Stateless extended query protocol messages.
|
class |
Parse |
class |
PasswordMessage |
class |
Query |
class |
ReadyForQuery |
class |
RowDescription |
class |
StartupMessage |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ByteBufMessageEncoder.encode(io.netty.channel.ChannelHandlerContext ctx,
Message msg,
io.netty.buffer.ByteBuf out) |
void |
NettyPgProtocolStream.send(Message message,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
| Modifier and Type | Method and Description |
|---|---|
void |
NettyPgProtocolStream.connect(StartupMessage startup,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
void |
NettyPgProtocolStream.send(java.util.List<Message> messages,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
void |
NettyPgProtocolStream.send(java.util.List<Message> messages,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
void |
NettyPgProtocolStream.send(Message message,
java.util.function.Consumer<java.util.List<Message>> replyTo) |
Copyright © 2014. All Rights Reserved.