Documentation
¶
Index ¶
- func DecodeNextCommand(r io.Reader, bufp *[]byte) (req serialized_messages.Request, err error)
- func DecodeNextReply(r io.Reader, bufp *[]byte) (reply serialized_messages.Reply, err error)
- func EncodeBatchWriteReplyWithFraming(builder *flatbuffers.Builder, nWritten, latencyNanos uint64)
- func EncodeReadReplyWithFraming(builder *flatbuffers.Builder, key, val []byte, latencyNanos uint64)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecodeNextCommand ¶
func DecodeNextReply ¶
func EncodeBatchWriteReplyWithFraming ¶
func EncodeBatchWriteReplyWithFraming(builder *flatbuffers.Builder, nWritten, latencyNanos uint64)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.