package
0.0.0-20241212002435-a4aaf8ca5232
Repository: https://github.com/chrislusf/gleam.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
# Functions
BufWrites ensures all writers are bufio.Writer For any bufio.Writer created here, flush it before returning.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
setup asynchronously to merge multiple channels into one channel.
DecodeRow decodes one row of data from a blob.
No description provided by the author
EncodeKeys encode keys to a blob, for comparing or sorting.
No description provided by the author
all data passing through pipe are all (size, msgpack_encoded) tuples The input and output should all be this msgpack format.
No description provided by the author
Fprintf reads MessagePack encoded messages from reader, and formats according to a format specifier and writes to writer.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
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.
No description provided by the author
No description provided by the author
ReadMessage reads out the []byte for one message.
ReadRow read and decode one row of data.
No description provided by the author
TakeMessage Reads and processes MessagePack encoded messages.
TakeTsv Reads and processes TSV lines.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
TsvPrintf reads TSV lines from reader, and formats according to a format specifier and writes to writer.
No description provided by the author
No description provided by the author
No description provided by the author
# Constants
No description provided by the author
No description provided by the author
# Structs
No description provided by the author
An Item is something we manage in a priority queue.
No description provided by the author
A PriorityQueue implements heap.Interface and holds Items.
No description provided by the author
# Type aliases
No description provided by the author