version

package
v0.0.0-...-0ebe720 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2021 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Compaction

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

func (*Compaction) Log

func (c *Compaction) Log()

type FileMetaData

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

func (*FileMetaData) DecodeFrom

func (meta *FileMetaData) DecodeFrom(r io.Reader) error

func (*FileMetaData) EncodeTo

func (meta *FileMetaData) EncodeTo(w io.Writer) error

type MergingIterator

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

func NewMergingIterator

func NewMergingIterator(list []*sstable.Iterator) *MergingIterator

func (*MergingIterator) InternalKey

func (it *MergingIterator) InternalKey() *internal.InternalKey

func (*MergingIterator) Next

func (it *MergingIterator) Next()

Advances to the next position. REQUIRES: Valid()

func (*MergingIterator) SeekToFirst

func (it *MergingIterator) SeekToFirst()

Position at the first entry in list. Final state of iterator is Valid() iff list is not empty.

func (*MergingIterator) Valid

func (it *MergingIterator) Valid() bool

Returns true iff the iterator is positioned at a valid node.

type TableCache

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

func NewTableCache

func NewTableCache(dbName string) *TableCache

func (*TableCache) Evict

func (tableCache *TableCache) Evict(fileNum uint64)

func (*TableCache) Get

func (tableCache *TableCache) Get(fileNum uint64, key []byte) ([]byte, error)

func (*TableCache) NewIterator

func (tableCache *TableCache) NewIterator(fileNum uint64) *sstable.Iterator

type Version

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

func Load

func Load(dbName string, number uint64) (*Version, error)

func New

func New(dbName string) *Version

func (*Version) Copy

func (v *Version) Copy() *Version

func (*Version) DecodeFrom

func (v *Version) DecodeFrom(r io.Reader) error

func (*Version) DoCompactionWork

func (v *Version) DoCompactionWork() bool

func (*Version) EncodeTo

func (v *Version) EncodeTo(w io.Writer) error

func (*Version) Get

func (v *Version) Get(key []byte) ([]byte, error)

func (*Version) Log

func (v *Version) Log()

func (*Version) NextSeq

func (v *Version) NextSeq() uint64

func (*Version) NumLevelFiles

func (v *Version) NumLevelFiles(l int) int

func (*Version) Save

func (v *Version) Save() (uint64, error)

func (*Version) WriteLevel0Table

func (v *Version) WriteLevel0Table(imm *memtable.MemTable)

Jump to

Keyboard shortcuts

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