BufWrites ensures all writers are bufio.Writer For any bufio.Writer created here, flush it before returning.

setup asynchronously to merge multiple channels into one channel.

DecodeRow decodes one row of data from a blob.

EncodeKeys encode keys to a blob, for comparing or sorting.

all data passing through pipe are all (size, msgpack_encoded) tuples The input and output should all be this msgpack format.

Fprintf reads MessagePack encoded messages from reader, and formats according to a format specifier and writes to writer.

PrintDelimited Reads and formats MessagePack encoded messages with delimiter and lineSeparator.

ProcessMessage Reads and processes MessagePack encoded messages until EOF.

ProcessRow Reads and processes rows until EOF.

ReadMessage reads out the []byte for one message.

ReadRow read and decode one row of data.

TakeMessage Reads and processes MessagePack encoded messages.

TakeTsv Reads and processes TSV lines.

TsvPrintf reads TSV lines from reader, and formats according to a format specifier and writes to writer.

An Item is something we manage in a priority queue.

A PriorityQueue implements heap.Interface and holds Items.