arenaskl

Documentation

Index

• Variables
• func MaxNodeSize(keySize, valueSize uint32) uint32
• type Arena
  • func NewArena(buf []byte) *Arena
  • func (a *Arena) Capacity() uint32
  • func (a *Arena) Size() uint32
• type Inserter
  • func (ins *Inserter) Add(list *Skiplist, key base.InternalKey, value []byte) error
• type Iterator
  • func (it *Iterator) Close() error
  • func (it *Iterator) Error() error
  • func (it *Iterator) First() (*base.InternalKey, []byte)
  • func (it *Iterator) Head() bool
  • func (it *Iterator) Last() (*base.InternalKey, []byte)
  • func (it *Iterator) Next() (*base.InternalKey, []byte)
  • func (it *Iterator) Prev() (*base.InternalKey, []byte)
  • func (it *Iterator) SeekGE(key []byte) (*base.InternalKey, []byte)
  • func (it *Iterator) SeekLT(key []byte) (*base.InternalKey, []byte)
  • func (it *Iterator) SeekPrefixGE(prefix, key []byte, trySeekUsingNext bool) (*base.InternalKey, []byte)
  • func (it *Iterator) SetBounds(lower, upper []byte)
  • func (it *Iterator) String() string
  • func (it *Iterator) Tail() bool
• type Skiplist
  • func NewSkiplist(arena *Arena, cmp base.Compare) *Skiplist
  • func (s *Skiplist) Add(key base.InternalKey, value []byte) error
  • func (s *Skiplist) Arena() *Arena
  • func (s *Skiplist) Get(key []byte) ([]byte, bool, base.InternalKeyKind)
  • func (s *Skiplist) Height() uint32
  • func (s *Skiplist) NewFlushIter(bytesFlushed *uint64) base.InternalIterator
  • func (s *Skiplist) NewIter(lower, upper []byte) *Iterator
  • func (s *Skiplist) Reset(arena *Arena, cmp base.Compare)
  • func (s *Skiplist) Size() uint32

Variables

var (
	ErrArenaFull = errors.New("allocation failed because arena is full")
)

var ErrRecordExists = errors.New("record with this key already exists")

Functions

func MaxNodeSize

func MaxNodeSize(keySize, valueSize uint32) uint32

Types

type Arena

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

func NewArena

func NewArena(buf []byte) *Arena

func (*Arena) Capacity

func (a *Arena) Capacity() uint32

func (*Arena) Size

func (a *Arena) Size() uint32

type Inserter

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

func (*Inserter) Add

func (ins *Inserter) Add(list *Skiplist, key base.InternalKey, value []byte) error

type Iterator

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

func (*Iterator) Close

func (it *Iterator) Close() error

func (*Iterator) Error

func (it *Iterator) Error() error

func (*Iterator) First

func (it *Iterator) First() (*base.InternalKey, []byte)

func (*Iterator) Head

func (it *Iterator) Head() bool

func (*Iterator) Last

func (it *Iterator) Last() (*base.InternalKey, []byte)

func (*Iterator) Next

func (it *Iterator) Next() (*base.InternalKey, []byte)

func (*Iterator) Prev

func (it *Iterator) Prev() (*base.InternalKey, []byte)

func (*Iterator) SeekGE

func (it *Iterator) SeekGE(key []byte) (*base.InternalKey, []byte)

func (*Iterator) SeekLT

func (it *Iterator) SeekLT(key []byte) (*base.InternalKey, []byte)

func (*Iterator) SeekPrefixGE

func (it *Iterator) SeekPrefixGE(
	prefix, key []byte, trySeekUsingNext bool,
) (*base.InternalKey, []byte)

func (*Iterator) SetBounds

func (it *Iterator) SetBounds(lower, upper []byte)

func (*Iterator) String

func (it *Iterator) String() string

func (*Iterator) Tail

func (it *Iterator) Tail() bool

type Skiplist

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

func NewSkiplist

func NewSkiplist(arena *Arena, cmp base.Compare) *Skiplist

func (*Skiplist) Add

func (s *Skiplist) Add(key base.InternalKey, value []byte) error

func (*Skiplist) Arena

func (s *Skiplist) Arena() *Arena

func (*Skiplist) Get

func (s *Skiplist) Get(key []byte) ([]byte, bool, base.InternalKeyKind)

func (*Skiplist) Height

func (s *Skiplist) Height() uint32

func (*Skiplist) NewFlushIter

func (s *Skiplist) NewFlushIter(bytesFlushed *uint64) base.InternalIterator

func (*Skiplist) NewIter

func (s *Skiplist) NewIter(lower, upper []byte) *Iterator

func (*Skiplist) Reset

func (s *Skiplist) Reset(arena *Arena, cmp base.Compare)

func (*Skiplist) Size

func (s *Skiplist) Size() uint32