Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildCompressReader ¶
func BuildCompressReader(rd ReadSeekerAt) (*kvfile.Reader, error)
BuildCompressReader reads key/value pairs from the compressed reader. Uses seekable zstd compression.
func WriteCompress ¶
func WriteCompress(writer io.Writer, keys [][]byte, writeValue func(wr io.Writer, key []byte) (uint64, error)) error
WriteCompress writes the given key/value pairs to the store in writer. Uses seekable zstd compression.
Serializes and writes the key/value pairs. Note: keys will be sorted by key. Note: keys must not contain duplicate keys. writeValue should write the given value to the writer returning the number of bytes written.
Types ¶
type ReadSeekerAt ¶
type ReadSeekerAt interface { io.ReadSeeker io.ReaderAt }
ReadSeekerAt is the interface BuildCompressReader accepts.
Click to show internal directories.
Click to hide internal directories.