sstable

Documentation

Index

• Variables
• func MergeSSTables(sstableWriter io.Writer, a, b keyvalue.KeyValueIterator, ...) (index.OffsetMap, error)
• func NewSSTableIterator(segmentFile *os.File, index *index.Index) keyvalue.SubIterator
• type SSTableReader
  • func NewSSTableReader(reader io.Reader) *SSTableReader
  • func (i *SSTableReader) Next() (keyvalue.IteratorEntry, error)
• type SSTableSeeker
  • func NewSSTableSeeker(reader io.ReadSeeker) *SSTableSeeker
  • func (r *SSTableSeeker) ReadAt(offset uint64) (keyvalue.IteratorEntry, error)
• type SSTableWriter
  • func NewSSTableWriter(writer io.Writer) *SSTableWriter
  • func (w *SSTableWriter) Write(entry keyvalue.IteratorEntry) (uint32, error)
  • func (w *SSTableWriter) WriteFromIterator(iterator keyvalue.KeyValueIterator) error
  • func (w *SSTableWriter) WriteFromIteratorUntil(iterator keyvalue.KeyValueIterator, maxSize uint64) error
  • func (w *SSTableWriter) WrittenOffsets() index.OffsetMap

Variables

var ErrIndexNotProvided = errors.New("index not provided")

Functions

func MergeSSTables

func MergeSSTables(sstableWriter io.Writer, a, b keyvalue.KeyValueIterator,
	members *segmentmembers.SegmentMembers) (index.OffsetMap, error)

func NewSSTableIterator

func NewSSTableIterator(segmentFile *os.File, index *index.Index) keyvalue.SubIterator

Types

type SSTableReader

type SSTableReader struct {
	// contains filtered or unexported fields
}

func NewSSTableReader

func NewSSTableReader(reader io.Reader) *SSTableReader

func (*SSTableReader) Next

func (i *SSTableReader) Next() (keyvalue.IteratorEntry, error)

type SSTableSeeker

type SSTableSeeker struct {
	// contains filtered or unexported fields
}

func NewSSTableSeeker

func NewSSTableSeeker(reader io.ReadSeeker) *SSTableSeeker

func (*SSTableSeeker) ReadAt

func (r *SSTableSeeker) ReadAt(offset uint64) (keyvalue.IteratorEntry, error)

type SSTableWriter

type SSTableWriter struct {
	// contains filtered or unexported fields
}

func NewSSTableWriter

func NewSSTableWriter(writer io.Writer) *SSTableWriter

func (*SSTableWriter) Write

func (w *SSTableWriter) Write(entry keyvalue.IteratorEntry) (uint32, error)

func (*SSTableWriter) WriteFromIterator

func (w *SSTableWriter) WriteFromIterator(iterator keyvalue.KeyValueIterator) error

func (*SSTableWriter) WriteFromIteratorUntil

func (w *SSTableWriter) WriteFromIteratorUntil(iterator keyvalue.KeyValueIterator, maxSize uint64) error

func (*SSTableWriter) WrittenOffsets

func (w *SSTableWriter) WrittenOffsets() index.OffsetMap