memiavl

package module

Go to main page

Versions in this module

v0

v0.0.6

Mar 11, 2024

v0.0.5

Nov 15, 2023

Changes in this version

+ const NodeChannelBuffer

+ const TmpSuffix

+ func NewCache(cacheSize int) cache.Cache

type DB

+ func (db *DB) ApplyChangeSets(changeSets []*NamedChangeSet) error

+ func (db *DB) SaveVersion(updateCommitInfo bool) ([]byte, int64, error)

+ func (db *DB) WorkingCommitInfo() *storetypes.CommitInfo

+ func (db *DB) WorkingHash() []byte

type MemNode

+ func (node *MemNode) SafeHash() []byte

type MultiTree

+ func (t *MultiTree) ApplyChangeSets(changeSets []*NamedChangeSet) error

+ func (t *MultiTree) SaveVersion(updateCommitInfo bool) ([]byte, int64, error)

+ func (t *MultiTree) WorkingCommitInfo() *storetypes.CommitInfo

+ func (t *MultiTree) WorkingHash() []byte

type Node

+ SafeHash func() []byte

type PersistedNode

+ func (node PersistedNode) SafeHash() []byte

v0.0.4

Aug 10, 2023

Changes in this version

+ const LockFileName

+ const SnapshotDirLen

+ func GetLatestVersion(dir string) (int64, error)

type DB

+ func (db *DB) CommittedVersion() (int64, error)

+ func (db *DB) ReadOnly() bool

+ type FileLock interface

+ Unlock func() error

+ func LockFile(fname string) (FileLock, error)

type MultiTree

+ func (t *MultiTree) Trees() []NamedTree

+ type NamedTree struct

+ Name string

type Options

+ LoadForOverwriting bool

+ ReadOnly bool

+ func (opts *Options) FillDefaults()

+ func (opts Options) Validate() error

v0.0.3

Jun 26, 2023

Changes in this version

+ func OpenWAL(dir string, opts *wal.Options) (*wal.Log, error)

type Options

+ SupportExportNonSnapshotVersion bool

+ TriggerStateSyncExport func(height int64)

v0.0.2

May 29, 2023

Changes in this version

+ const DefaultSnapshotInterval

+ const FileNameKVIndex

+ const FileNameKVs

+ const FileNameLeaves

+ const FileNameMetadata

+ const FileNameNodes

+ const MetadataFileName

+ const OffsetKeyLeaf

+ const OffsetLeafHash

+ const OffsetLeafKeyLen

+ const OffsetLeafKeyOffset

+ const OffsetLeafVersion

+ const OffsetPreTrees

+ const SizeLeaf

+ const SizeLeafWithoutHash

+ const SnapshotPrefix

+ var ErrIntOverflowWal = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthWal = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupWal = fmt.Errorf("proto: unexpected end of group")

+ func Import(dir string, height uint64, format uint32, protoReader protoio.Reader) (snapshottypes.SnapshotItem, error)

+ func NewIterator(start, end []byte, ascending bool, root Node, zeroCopy bool) dbm.Iterator

+ func WriteFileSync(name string, data []byte) error

+ type DB struct

+ func Load(dir string, opts Options) (*DB, error)

+ func (db *DB) ApplyChangeSet(changeSets []*NamedChangeSet, updateCommitInfo bool) ([]byte, int64, error)

+ func (db *DB) ApplyUpgrades(upgrades []*TreeNameUpgrade) error

+ func (db *DB) Close() error

+ func (db *DB) Commit(changeSets []*NamedChangeSet) ([]byte, int64, error)

+ func (db *DB) Copy() *DB

+ func (db *DB) Hash() []byte

+ func (db *DB) LastCommitInfo() *storetypes.CommitInfo

+ func (db *DB) Reload() error

+ func (db *DB) RewriteSnapshot() error

+ func (db *DB) RewriteSnapshotBackground() error

+ func (db *DB) SetInitialVersion(initialVersion int64) error

+ func (db *DB) Snapshot(height uint64, protoWriter protoio.Writer) error

+ func (db *DB) TreeByName(name string) *Tree

+ func (db *DB) UpdateCommitInfo() []byte

+ func (db *DB) Version() int64

+ func (db *DB) WaitAsyncCommit() error

+ func (db *DB) WriteSnapshot(dir string) error

+ type Exporter struct

+ func (e *Exporter) Close()

+ func (e *Exporter) Next() (*iavl.ExportNode, error)

+ type Iterator struct

+ func (iter *Iterator) Close() error

+ func (iter *Iterator) Domain() ([]byte, []byte)

+ func (iter *Iterator) Error() error

+ func (iter *Iterator) Key() []byte

+ func (iter *Iterator) Next()

+ func (iter *Iterator) Valid() bool

+ func (iter *Iterator) Value() []byte

+ type LeafLayout struct

+ func (leaf LeafLayout) Hash() []byte

+ func (leaf LeafLayout) KeyLength() uint32

+ func (leaf LeafLayout) KeyOffset() uint64

+ func (leaf LeafLayout) Version() uint32

+ type Leaves struct

+ func NewLeaves(data []byte) (Leaves, error)

+ func (leaves Leaves) Leaf(i uint32) LeafLayout

type MemNode

+ func (node *MemNode) Get(key []byte) ([]byte, uint32)

+ func (node *MemNode) GetByIndex(index uint32) ([]byte, []byte)

+ func (node *MemNode) IsLeaf() bool

+ type MultiTree struct

+ func LoadMultiTree(dir string, zeroCopy bool, cacheSize int) (*MultiTree, error)

+ func NewEmptyMultiTree(initialVersion uint32, cacheSize int) *MultiTree

+ func (t *MultiTree) ApplyChangeSet(changeSets []*NamedChangeSet, updateCommitInfo bool) ([]byte, int64, error)

+ func (t *MultiTree) ApplyUpgrades(upgrades []*TreeNameUpgrade) error

+ func (t *MultiTree) CatchupWAL(wal *wal.Log, endVersion int64) error

+ func (t *MultiTree) Close() error

+ func (t *MultiTree) Copy(cacheSize int) *MultiTree

+ func (t *MultiTree) Hash() []byte

+ func (t *MultiTree) LastCommitInfo() *storetypes.CommitInfo

+ func (t *MultiTree) SetInitialVersion(initialVersion int64) error

+ func (t *MultiTree) SetZeroCopy(zeroCopy bool)

+ func (t *MultiTree) SnapshotVersion() int64

+ func (t *MultiTree) TreeByName(name string) *Tree

+ func (t *MultiTree) UpdateCommitInfo() []byte

+ func (t *MultiTree) Version() int64

+ func (t *MultiTree) WriteSnapshot(dir string) error

+ type MultiTreeMetadata struct

+ CommitInfo *types.CommitInfo

+ InitialVersion int64

+ func (*MultiTreeMetadata) Descriptor() ([]byte, []int)

+ func (*MultiTreeMetadata) ProtoMessage()

+ func (m *MultiTreeMetadata) GetCommitInfo() *types.CommitInfo

+ func (m *MultiTreeMetadata) GetInitialVersion() int64

+ func (m *MultiTreeMetadata) Marshal() (dAtA []byte, err error)

+ func (m *MultiTreeMetadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *MultiTreeMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MultiTreeMetadata) Reset()

+ func (m *MultiTreeMetadata) Size() (n int)

+ func (m *MultiTreeMetadata) String() string

+ func (m *MultiTreeMetadata) Unmarshal(dAtA []byte) error

+ func (m *MultiTreeMetadata) XXX_DiscardUnknown()

+ func (m *MultiTreeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MultiTreeMetadata) XXX_Merge(src proto.Message)

+ func (m *MultiTreeMetadata) XXX_Size() int

+ func (m *MultiTreeMetadata) XXX_Unmarshal(b []byte) error

+ type NamedChangeSet struct

+ Changeset proto1.ChangeSet

+ Name string

+ func (*NamedChangeSet) Descriptor() ([]byte, []int)

+ func (*NamedChangeSet) ProtoMessage()

+ func (m *NamedChangeSet) GetChangeset() proto1.ChangeSet

+ func (m *NamedChangeSet) GetName() string

+ func (m *NamedChangeSet) Marshal() (dAtA []byte, err error)

+ func (m *NamedChangeSet) MarshalTo(dAtA []byte) (int, error)

+ func (m *NamedChangeSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NamedChangeSet) Reset()

+ func (m *NamedChangeSet) Size() (n int)

+ func (m *NamedChangeSet) String() string

+ func (m *NamedChangeSet) Unmarshal(dAtA []byte) error

+ func (m *NamedChangeSet) XXX_DiscardUnknown()

+ func (m *NamedChangeSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NamedChangeSet) XXX_Merge(src proto.Message)

+ func (m *NamedChangeSet) XXX_Size() int

+ func (m *NamedChangeSet) XXX_Unmarshal(b []byte) error

type Node

+ Get func(key []byte) ([]byte, uint32)

+ GetByIndex func(uint32) ([]byte, []byte)

+ IsLeaf func() bool

+ type NodeLayout struct

+ func (node NodeLayout) Hash() []byte

+ func (node NodeLayout) Height() uint8

+ func (node NodeLayout) KeyLeaf() uint32

+ func (node NodeLayout) PreTrees() uint8

+ func (node NodeLayout) Size() uint32

+ func (node NodeLayout) Version() uint32

+ type Nodes struct

+ func NewNodes(data []byte) (Nodes, error)

+ func (nodes Nodes) Node(i uint32) NodeLayout

+ type Options struct

+ AsyncCommitBuffer int

+ CacheSize int

+ CreateIfMissing bool

+ InitialStores []string

+ InitialVersion uint32

+ Logger log.Logger

+ MinQueryStates int

+ SnapshotInterval uint32

+ SnapshotKeepRecent uint32

+ TargetVersion uint32

+ ZeroCopy bool

type PersistedNode

+ func (node PersistedNode) Get(key []byte) ([]byte, uint32)

+ func (node PersistedNode) GetByIndex(leafIndex uint32) ([]byte, []byte)

+ func (node PersistedNode) IsLeaf() bool

type Snapshot

+ func NewEmptySnapshot(version uint32) *Snapshot

+ func (snapshot *Snapshot) Export() *Exporter

+ func (snapshot *Snapshot) Get(key []byte) []byte

+ func (snapshot *Snapshot) IsEmpty() bool

+ func (snapshot *Snapshot) Key(offset uint64) []byte

+ func (snapshot *Snapshot) KeyValue(offset uint64) ([]byte, []byte)

+ func (snapshot *Snapshot) Leaf(index uint32) PersistedNode

+ func (snapshot *Snapshot) LeafKey(index uint32) []byte

+ func (snapshot *Snapshot) LeafKeyValue(index uint32) ([]byte, []byte)

+ func (snapshot *Snapshot) RootHash() []byte

+ func (snapshot *Snapshot) ScanNodes(callback func(node PersistedNode) error) error

+ func (snapshot *Snapshot) Version() uint32

type Tree

+ func NewFromSnapshot(snapshot *Snapshot, zeroCopy bool, cacheSize int) *Tree

+ func (t *Tree) ApplyChangeSet(changeSet iavl.ChangeSet, updateHash bool) ([]byte, int64, error)

+ func (t *Tree) Close() error

+ func (t *Tree) Copy(cacheSize int) *Tree

+ func (t *Tree) Export() *Exporter

+ func (t *Tree) Get(key []byte) []byte

+ func (t *Tree) GetByIndex(index int64) ([]byte, []byte)

+ func (t *Tree) GetMembershipProof(key []byte) (*ics23.CommitmentProof, error)

+ func (t *Tree) GetNonMembershipProof(key []byte) (*ics23.CommitmentProof, error)

+ func (t *Tree) GetWithIndex(key []byte) (int64, []byte)

+ func (t *Tree) Has(key []byte) bool

+ func (t *Tree) IsEmpty() bool

+ func (t *Tree) Iterator(start, end []byte, ascending bool) dbm.Iterator

+ func (t *Tree) ScanPostOrder(callback func(node Node) bool)

+ func (t *Tree) SetInitialVersion(initialVersion int64) error

+ func (t *Tree) SetZeroCopy(zeroCopy bool)

+ func (t *Tree) VerifyMembership(proof *ics23.CommitmentProof, key []byte) bool

+ func (t *Tree) VerifyNonMembership(proof *ics23.CommitmentProof, key []byte) bool

+ type TreeImporter struct

+ func NewTreeImporter(dir string, version int64) *TreeImporter

+ func (ai *TreeImporter) Add(node *iavl.ExportNode)

+ func (ai *TreeImporter) Close() error

+ type TreeNameUpgrade struct

+ Delete bool

+ Name string

+ RenameFrom string

+ func (*TreeNameUpgrade) Descriptor() ([]byte, []int)

+ func (*TreeNameUpgrade) ProtoMessage()

+ func (m *TreeNameUpgrade) GetDelete() bool

+ func (m *TreeNameUpgrade) GetName() string

+ func (m *TreeNameUpgrade) GetRenameFrom() string

+ func (m *TreeNameUpgrade) Marshal() (dAtA []byte, err error)

+ func (m *TreeNameUpgrade) MarshalTo(dAtA []byte) (int, error)

+ func (m *TreeNameUpgrade) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TreeNameUpgrade) Reset()

+ func (m *TreeNameUpgrade) Size() (n int)

+ func (m *TreeNameUpgrade) String() string

+ func (m *TreeNameUpgrade) Unmarshal(dAtA []byte) error

+ func (m *TreeNameUpgrade) XXX_DiscardUnknown()

+ func (m *TreeNameUpgrade) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TreeNameUpgrade) XXX_Merge(src proto.Message)

+ func (m *TreeNameUpgrade) XXX_Size() int

+ func (m *TreeNameUpgrade) XXX_Unmarshal(b []byte) error

+ type WALEntry struct

+ Changesets []*NamedChangeSet

+ Upgrades []*TreeNameUpgrade

+ func (*WALEntry) Descriptor() ([]byte, []int)

+ func (*WALEntry) ProtoMessage()

+ func (m *WALEntry) GetChangesets() []*NamedChangeSet

+ func (m *WALEntry) GetUpgrades() []*TreeNameUpgrade

+ func (m *WALEntry) Marshal() (dAtA []byte, err error)

+ func (m *WALEntry) MarshalTo(dAtA []byte) (int, error)

+ func (m *WALEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WALEntry) Reset()

+ func (m *WALEntry) Size() (n int)

+ func (m *WALEntry) String() string

+ func (m *WALEntry) Unmarshal(dAtA []byte) error

+ func (m *WALEntry) XXX_DiscardUnknown()

+ func (m *WALEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WALEntry) XXX_Merge(src proto.Message)

+ func (m *WALEntry) XXX_Size() int

+ func (m *WALEntry) XXX_Unmarshal(b []byte) error

v0.0.1

Feb 4, 2023

v0.0.0

Feb 4, 2023

Changes in this version

+ const OffsetHash

+ const OffsetHeight

+ const OffsetKey

+ const OffsetLeft

+ const OffsetRight

+ const OffsetSize

+ const OffsetValue

+ const OffsetVersion

+ const SizeHash

+ const SizeKeyLen

+ const SizeMetadata

+ const SizeNode

+ const SizeNodeWithoutHash

+ const SizeValueLen

+ const SnapshotFileMagic

+ const SnapshotFormat

+ func EncodeBytes(w io.Writer, bz []byte) error

+ func HashNode(node Node) []byte

+ func LoadTreeFromSnapshot(snapshotDir string) (*Tree, *Snapshot, error)

+ func Mmap(f *os.File) ([]byte, *[mmap.MaxMapSize]byte, error)

+ func VerifyHash(node Node) bool

+ type MemNode struct

+ func (node *MemNode) Hash() []byte

+ func (node *MemNode) Height() int8

+ func (node *MemNode) Key() []byte

+ func (node *MemNode) Left() Node

+ func (node *MemNode) Mutate(version int64) *MemNode

+ func (node *MemNode) Right() Node

+ func (node *MemNode) Size() int64

+ func (node *MemNode) Value() []byte

+ func (node *MemNode) Version() int64

+ type MmapFile struct

+ func NewMmap(path string) (*MmapFile, error)

+ func (m *MmapFile) Close() error

+ func (m *MmapFile) Data() []byte

+ type Node interface

+ Hash func() []byte

+ Height func() int8

+ Key func() []byte

+ Left func() Node

+ Mutate func(version int64) *MemNode

+ Right func() Node

+ Size func() int64

+ Value func() []byte

+ Version func() int64

+ type PersistedNode struct

+ func (node PersistedNode) Hash() []byte

+ func (node PersistedNode) Height() int8

+ func (node PersistedNode) Key() []byte

+ func (node PersistedNode) Left() Node

+ func (node PersistedNode) Mutate(version int64) *MemNode

+ func (node PersistedNode) Right() Node

+ func (node PersistedNode) Size() int64

+ func (node PersistedNode) Value() []byte

+ func (node PersistedNode) Version() int64

+ type Snapshot struct

+ func OpenSnapshot(snapshotDir string) (*Snapshot, error)

+ func (snapshot *Snapshot) Close() error

+ func (snapshot *Snapshot) Node(index uint32) PersistedNode

+ func (snapshot *Snapshot) NodesLen() int

+ func (snapshot *Snapshot) RootNode() PersistedNode

+ type Tree struct

+ func New() *Tree

+ func NewEmptyTree(version int64) *Tree

+ func NewWithInitialVersion(initialVersion int64) *Tree

+ func (t *Tree) Remove(key []byte)

+ func (t *Tree) RootHash() []byte

+ func (t *Tree) SaveVersion(updateHash bool) ([]byte, int64, error)

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

+ func (t *Tree) Version() int64

+ func (t *Tree) WriteSnapshot(snapshotDir string) error

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