memtable

Documentation

Index

• type GostoreMemTable
  • func (mem *GostoreMemTable) Clear()
  • func (mem *GostoreMemTable) Close() error
  • func (mem *GostoreMemTable) Delete(key []byte)
  • func (mem *GostoreMemTable) FlushedTables() <-chan *sstable.SSTable
  • func (mem *GostoreMemTable) Get(key []byte) ([]byte, bool)
  • func (mem *GostoreMemTable) Put(key []byte, val []byte) error
  • func (mem *GostoreMemTable) Size() uint
  • func (mem *GostoreMemTable) Snapshot() *sstable.SSTable
• type MemTable
  • func New(opts *Opts) (MemTable, error)
• type Opts

Types

type GostoreMemTable

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

func (*GostoreMemTable) Clear

func (mem *GostoreMemTable) Clear()

func (*GostoreMemTable) Close

func (mem *GostoreMemTable) Close() error

func (*GostoreMemTable) Delete

func (mem *GostoreMemTable) Delete(key []byte)

func (*GostoreMemTable) FlushedTables

func (mem *GostoreMemTable) FlushedTables() <-chan *sstable.SSTable

func (*GostoreMemTable) Get

func (mem *GostoreMemTable) Get(key []byte) ([]byte, bool)

func (*GostoreMemTable) Put

func (mem *GostoreMemTable) Put(key []byte, val []byte) error

func (*GostoreMemTable) Size

func (mem *GostoreMemTable) Size() uint

func (*GostoreMemTable) Snapshot

func (mem *GostoreMemTable) Snapshot() *sstable.SSTable

Returns an SSTable filled with entries, with no size

type MemTable

type MemTable interface {
	io.Closer
	Put([]byte, []byte) error  // Insert Node to memTable
	Get([]byte) ([]byte, bool) // Get returns a value associated with the key
	Delete([]byte)             // Insert a node marked as delete
	Size() uint                // Number of entries
	Clear()                    // Wipe the memtable

	FlushedTables() <-chan *sstable.SSTable
}

In-memory balanced key-value store

func New

func New(opts *Opts) (MemTable, error)

type Opts

type Opts struct {
	Batch_write_size int
	WalPath          string
	Max_size         uint
	FilterOpts       *filter.Opts
	LevelZero        string
}