avl

Documentation

Index

• Constants
• Variables
• func DeserializeFromDifference(r io.Reader, localViewID uint64) (*node, error)
• type GCProfile
  • func (profile *GCProfile) PerformFullGC() (int, error)
• type Tree
  • func New(kv store.KV) *Tree
  • func (t *Tree) ApplyDiff(diff io.Reader) error
  • func (t *Tree) ApplyDiffWithUpdateNotifier(diff io.Reader, updateNotifier func(key, value []byte)) error
  • func (t *Tree) Checksum() [MerkleHashSize]byte
  • func (t *Tree) Commit() error
  • func (t *Tree) Delete(k []byte) bool
  • func (t *Tree) DumpDiff(prevViewID uint64, wr io.Writer) error
  • func (t *Tree) GetGCProfile(preserveDepth uint64) *GCProfile
  • func (t *Tree) Insert(key, value []byte)
  • func (t *Tree) Iterate(callback func(key, value []byte))
  • func (t *Tree) IterateFrom(key []byte, callback func(key, value []byte) bool)
  • func (t *Tree) IterateLeafDiff(prevViewID uint64, callback func(key, value []byte) bool)
  • func (t *Tree) IteratePrefix(prefix []byte, callback func(key, value []byte))
  • func (t *Tree) Lookup(k []byte) ([]byte, bool)
  • func (t *Tree) PrintContents()
  • func (t *Tree) Revert(snapshot *Tree)
  • func (t *Tree) SetViewID(viewID uint64)
  • func (t *Tree) Snapshot() *Tree
  • func (t *Tree) WithLRUCache(size *int) *Tree
  • func (t *Tree) WithMaxWriteBatchSize(maxWriteBatchSize int) *Tree

Constants

const (
	MerkleHashSize = 16

	NodeNonLeaf nodeType = iota
	NodeLeafValue
)

const DefaultCacheSize = 2048

const MaxWriteBatchSize = 1024

Variables

var DiffsKeyPrefix = []byte("diffs:")

var GCAliveMarkPrefix = []byte("@2:")

var NextOldRootIndexKey = []byte(".next_old_root")

var NodeKeyPrefix = []byte("@1:")

var OldRootsPrefix = []byte("@3:")

var RootKey = []byte(".root")

Functions

func DeserializeFromDifference

func DeserializeFromDifference(r io.Reader, localViewID uint64) (*node, error)

Types

type GCProfile

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

func (*GCProfile) PerformFullGC

func (profile *GCProfile) PerformFullGC() (int, error)

type Tree

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

func New

func New(kv store.KV) *Tree

func (*Tree) ApplyDiff

func (t *Tree) ApplyDiff(diff io.Reader) error

func (*Tree) ApplyDiffWithUpdateNotifier

func (t *Tree) ApplyDiffWithUpdateNotifier(diff io.Reader, updateNotifier func(key, value []byte)) error

func (*Tree) Checksum

func (t *Tree) Checksum() [MerkleHashSize]byte

func (*Tree) Commit

func (t *Tree) Commit() error

func (*Tree) Delete

func (t *Tree) Delete(k []byte) bool

func (*Tree) DumpDiff

func (t *Tree) DumpDiff(prevViewID uint64, wr io.Writer) error

DumpDiff writes the AVL tree difference into a io.Writer.

func (*Tree) GetGCProfile

func (t *Tree) GetGCProfile(preserveDepth uint64) *GCProfile

func (*Tree) Insert

func (t *Tree) Insert(key, value []byte)

func (*Tree) Iterate

func (t *Tree) Iterate(callback func(key, value []byte))

func (*Tree) IterateFrom

func (t *Tree) IterateFrom(key []byte, callback func(key, value []byte) bool)

func (*Tree) IterateLeafDiff

func (t *Tree) IterateLeafDiff(prevViewID uint64, callback func(key, value []byte) bool)

func (*Tree) IteratePrefix

func (t *Tree) IteratePrefix(prefix []byte, callback func(key, value []byte))

func (*Tree) Lookup

func (t *Tree) Lookup(k []byte) ([]byte, bool)

func (*Tree) PrintContents

func (t *Tree) PrintContents()

func (*Tree) Revert

func (t *Tree) Revert(snapshot *Tree)

func (*Tree) SetViewID

func (t *Tree) SetViewID(viewID uint64)

func (*Tree) Snapshot

func (t *Tree) Snapshot() *Tree

func (*Tree) WithLRUCache

func (t *Tree) WithLRUCache(size *int) *Tree

func (*Tree) WithMaxWriteBatchSize

func (t *Tree) WithMaxWriteBatchSize(maxWriteBatchSize int) *Tree