table

Aug 28, 2024

retracted

Changes in this version

+ type Block struct

Feb 27, 2023

retracted

Changes in this version

+ const KB

+ const MB

+ var NOCACHE int = 4

+ var NumBlocks atomic.Int32

+ var REVERSED int = 2

+ func BlockEvictHandler(value interface{})

+ func IDToFilename(id uint64) string

+ func NewFilename(id uint64, dir string) string

+ func NewMergeIterator(iters []y.Iterator, reverse bool) y.Iterator

+ func ParseFileID(name string) (uint64, bool)

+ type Builder struct

+ func NewTableBuilder(opts Options) *Builder

+ func (b *Builder) Add(key []byte, value y.ValueStruct, valueLen uint32)

+ func (b *Builder) AddStaleKey(key []byte, v y.ValueStruct, valueLen uint32)

+ func (b *Builder) Close()

+ func (b *Builder) DataKey() *pb.DataKey

+ func (b *Builder) Done() buildData

+ func (b *Builder) Empty() bool

+ func (b *Builder) Finish() []byte

+ func (b *Builder) Opts() *Options

+ func (b *Builder) ReachedCapacity() bool

+ type ConcatIterator struct

+ func NewConcatIterator(tbls []*Table, opt int) *ConcatIterator

+ func (s *ConcatIterator) Close() error

+ func (s *ConcatIterator) Key() []byte

+ func (s *ConcatIterator) Next()

+ func (s *ConcatIterator) Rewind()

+ func (s *ConcatIterator) Seek(key []byte)

+ func (s *ConcatIterator) Valid() bool

+ func (s *ConcatIterator) Value() y.ValueStruct

+ type Iterator struct

+ func (itr *Iterator) Close() error

+ func (itr *Iterator) Key() []byte

+ func (itr *Iterator) Next()

+ func (itr *Iterator) Rewind()

+ func (itr *Iterator) Seek(key []byte)

+ func (itr *Iterator) Valid() bool

+ func (itr *Iterator) Value() (ret y.ValueStruct)

+ func (itr *Iterator) ValueCopy() (ret y.ValueStruct)

+ type MergeIterator struct

+ func (mi *MergeIterator) Close() error

+ func (mi *MergeIterator) Key() []byte

+ func (mi *MergeIterator) Next()

+ func (mi *MergeIterator) Rewind()

+ func (mi *MergeIterator) Seek(key []byte)

+ func (mi *MergeIterator) Valid() bool

+ func (mi *MergeIterator) Value() y.ValueStruct

+ type Options struct

+ AllocPool *z.AllocatorPool

+ BlockCache *ristretto.Cache

+ BlockSize int

+ BloomFalsePositive float64

+ ChkMode options.ChecksumVerificationMode

+ Compression options.CompressionType

+ DataKey *pb.DataKey

+ IndexCache *ristretto.Cache

+ MetricsEnabled bool

+ ReadOnly bool

+ TableSize uint64

+ ZSTDCompressionLevel int

+ type Table struct

+ Checksum []byte

+ CreatedAt time.Time

+ IsInmemory bool

+ func CreateTable(fname string, builder *Builder) (*Table, error)

+ func OpenInMemoryTable(data []byte, id uint64, opt *Options) (*Table, error)

+ func OpenTable(mf *z.MmapFile, opts Options) (*Table, error)

+ func (t *Table) Biggest() []byte

+ func (t *Table) BloomFilterSize() int

+ func (t *Table) CompressionType() options.CompressionType

+ func (t *Table) DecrRef() error

+ func (t *Table) DoesNotHave(hash uint32) bool

+ func (t *Table) Filename() string

+ func (t *Table) ID() uint64

+ func (t *Table) IncrRef()

+ func (t *Table) IndexSize() int

+ func (t *Table) KeyCount() uint32

+ func (t *Table) KeyID() uint64

+ func (t *Table) KeySplits(n int, prefix []byte) []string

+ func (t *Table) MaxVersion() uint64

+ func (t *Table) NewIterator(opt int) *Iterator

+ func (t *Table) OnDiskSize() uint32

+ func (t *Table) Size() int64

+ func (t *Table) Smallest() []byte

+ func (t *Table) StaleDataSize() uint32

+ func (t *Table) UncompressedSize() uint32

+ func (t *Table) VerifyChecksum() error

+ type TableInterface interface

+ Biggest func() []byte

+ DoesNotHave func(hash uint32) bool

+ MaxVersion func() uint64

+ Smallest func() []byte