memtable

Documentation

Index

• type RollingMemtable
  • func NewRollingMemtable() RollingMemtable
  • func (m *RollingMemtable) FlushActive()
  • func (m *RollingMemtable) Get(key string) (mvcc.Element, bool)
  • func (m *RollingMemtable) Set(elem mvcc.Element) bool

Types

type RollingMemtable

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

RollingMemtable contains the dataset in memory It is flushed to disk at regular interval

func NewRollingMemtable

func NewRollingMemtable() RollingMemtable

NewRollingMemtable create a new rollingMemtable

func (*RollingMemtable) FlushActive

func (m *RollingMemtable) FlushActive()

FlushActive add the active memtable and add it to the flush queue

func (*RollingMemtable) Get

func (m *RollingMemtable) Get(key string) (mvcc.Element, bool)

Get a key from the memtables

func (*RollingMemtable) Set

func (m *RollingMemtable) Set(elem mvcc.Element) bool

Set a key to the active memtable