sstables

package

Go to main page

Versions in this module

v1

v1.6.1

Dec 13, 2024

v1.6.0

Nov 7, 2024

v1.5.0

Jul 28, 2024

Changes in this version

+ var ChecksumErr = ChecksumError

+ type ChecksumError struct

+ func (e ChecksumError) Error() string

+ func (e ChecksumError) Is(err error) bool

type ReadOption

+ func EnableHashCheckOnReads() ReadOption

+ func SkipHashCheckOnLoad() ReadOption

+ func SkipInvalidHashesOnLoad() ReadOption

+ type ReduceFunc func([]byte, [][]byte, []int) ([]byte, []byte)

v1.4.0

Dec 2, 2022

Changes in this version

+ type SSTableMergeIteratorContext struct

+ func NewMergeIteratorContext(context int, iterator SSTableIteratorI) SSTableMergeIteratorContext

+ func (s SSTableMergeIteratorContext) Context() int

+ func (s SSTableMergeIteratorContext) Next() ([]byte, []byte, error)

v1.3.1

Sep 15, 2021

v1.3.0

Aug 27, 2021

Changes in this version

+ var Version = uint32(1)

+ func ScanReduceLatestWins(key []byte, values [][]byte, context []interface{}) ([]byte, []byte)

+ type EmptySSTableIterator struct

+ func (EmptySSTableIterator) Next() ([]byte, []byte, error)

+ type EmptySStableReader struct

+ func (EmptySStableReader) BasePath() string

+ func (EmptySStableReader) Close() error

+ func (EmptySStableReader) Contains(_ []byte) bool

+ func (EmptySStableReader) Get(_ []byte) ([]byte, error)

+ func (EmptySStableReader) MetaData() *proto.MetaData

+ func (EmptySStableReader) Scan() (SSTableIteratorI, error)

+ func (EmptySStableReader) ScanRange(_ []byte, _ []byte) (SSTableIteratorI, error)

+ func (EmptySStableReader) ScanStartingAt(_ []byte) (SSTableIteratorI, error)

+ type MergeCompactionIterator struct

+ func (m *MergeCompactionIterator) Next() ([]byte, []byte, error)

+ type MergeContext struct

+ IteratorContext []interface{}

+ Iterators []SSTableIteratorI

+ type SSTableFullScanIterator struct

+ func (it *SSTableFullScanIterator) Next() ([]byte, []byte, error)

type SSTableMerger

+ func (m SSTableMerger) MergeCompact(ctx MergeContext, writer SSTableStreamWriterI, ...) error

+ func (m SSTableMerger) MergeCompactIterator(ctx MergeContext, ...) (SSTableIteratorI, error)

type SSTableMergerI

+ MergeCompact func(iterators []SSTableIteratorI, writer SSTableStreamWriterI, ...) error

type SSTableReader

+ func (reader *SSTableReader) BasePath() string

type SSTableReaderI

+ BasePath func() string

+ type SuperSSTableReader struct

+ func NewSuperSSTableReader(readers []SSTableReaderI, comp skiplist.KeyComparator) *SuperSSTableReader

+ func (s SuperSSTableReader) BasePath() string

+ func (s SuperSSTableReader) Close() error

+ func (s SuperSSTableReader) Contains(key []byte) bool

+ func (s SuperSSTableReader) Get(key []byte) ([]byte, error)

+ func (s SuperSSTableReader) MetaData() *proto.MetaData

+ func (s SuperSSTableReader) Scan() (SSTableIteratorI, error)

+ func (s SuperSSTableReader) ScanRange(keyLower []byte, keyHigher []byte) (SSTableIteratorI, error)

+ func (s SuperSSTableReader) ScanStartingAt(key []byte) (SSTableIteratorI, error)

+ type V0SSTableFullScanIterator struct

+ func (it *V0SSTableFullScanIterator) Next() ([]byte, []byte, error)

type WriterOption

+ func WriteBufferSizeBytes(bufSizeBytes int) WriterOption

v1.2.0

Jun 6, 2021

v1.1.0

Oct 24, 2020

Changes in this version

+ type Element struct

+ type PriorityQueue struct

+ func NewPriorityQueue(comp skiplist.KeyComparator) PriorityQueue

+ func (pq *PriorityQueue) Init(iterators []SSTableIteratorI) error

+ func (pq *PriorityQueue) Next() ([]byte, []byte, error)

+ type PriorityQueueI interface

+ Init func(iterators []SSTableIteratorI) error

+ Next func() ([]byte, []byte, error)

+ type SSTableMerger struct

+ func NewSSTableMerger(comp skiplist.KeyComparator) SSTableMerger

+ func (m SSTableMerger) Merge(iterators []SSTableIteratorI, writer SSTableStreamWriterI) error

+ type SSTableMergerI interface

+ Merge func(iterators []SSTableIteratorI, writer SSTableStreamWriterI) error

type SSTableReader

+ func (reader *SSTableReader) Scan() (SSTableIteratorI, error)

type SSTableReaderI

+ Scan func() (SSTableIteratorI, error)

v1.0.0

Jan 12, 2019

Changes in this version

+ var BloomFileName = "bloom.bf.gz"

+ var DataFileName = "data.rio"

+ var Done = errors.New("no more items in iterator")

+ var IndexFileName = "index.rio"

+ var MetaFileName = "meta.pb.bin"

+ var NotFound = errors.New("key was not found")

+ type ReadOption func(*SSTableReaderOptions)

+ func ReadBasePath(p string) ReadOption

+ func ReadWithKeyComparator(cmp skiplist.KeyComparator) ReadOption

+ type SSTableIterator struct

+ func (it *SSTableIterator) Next() ([]byte, []byte, error)

+ type SSTableIteratorI interface

+ Next func() ([]byte, []byte, error)

+ type SSTableReader struct

+ func (reader *SSTableReader) Close() error

+ func (reader *SSTableReader) Contains(key []byte) bool

+ func (reader *SSTableReader) Get(key []byte) ([]byte, error)

+ func (reader *SSTableReader) MetaData() *proto.MetaData

+ func (reader *SSTableReader) ScanRange(keyLower []byte, keyHigher []byte) (SSTableIteratorI, error)

+ func (reader *SSTableReader) ScanStartingAt(key []byte) (SSTableIteratorI, error)

+ type SSTableReaderI interface

+ Close func() error

+ Contains func(key []byte) bool

+ Get func(key []byte) ([]byte, error)

+ MetaData func() *proto.MetaData

+ ScanRange func(keyLower []byte, keyHigher []byte) (SSTableIteratorI, error)

+ ScanStartingAt func(key []byte) (SSTableIteratorI, error)

+ func NewSSTableReader(readerOptions ...ReadOption) (SSTableReaderI, error)

+ type SSTableReaderOptions struct

+ type SSTableSimpleWriter struct

+ func NewSSTableSimpleWriter(writerOptions ...WriterOption) (*SSTableSimpleWriter, error)

+ func (writer *SSTableSimpleWriter) WriteSkipListMap(skipListMap *skiplist.SkipListMap) error

+ type SSTableSimpleWriterI interface

+ WriteSkipList func(skipListMap *skiplist.SkipListMap) error

+ type SSTableStreamWriter struct

+ func NewSSTableStreamWriter(writerOptions ...WriterOption) (*SSTableStreamWriter, error)

+ func (writer *SSTableStreamWriter) Close() error

+ func (writer *SSTableStreamWriter) Open() error

+ func (writer *SSTableStreamWriter) WriteNext(key []byte, value []byte) error

+ type SSTableStreamWriterI interface

+ Close func() error

+ Open func() error

+ WriteNext func(key []byte, value []byte) error

+ type SSTableWriterOptions struct

+ type WriterOption func(*SSTableWriterOptions)

+ func BloomExpectedNumberOfElements(n uint64) WriterOption

+ func BloomFalsePositiveProbability(fpProbability float64) WriterOption

+ func DataCompressionType(p int) WriterOption

+ func EnableBloomFilter() WriterOption

+ func IndexCompressionType(p int) WriterOption

+ func WithKeyComparator(cmp skiplist.KeyComparator) WriterOption

+ func WriteBasePath(p string) WriterOption

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL