Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

memiavl

package

Go to main page

Versions in this module

v0

v0.0.22

Nov 15, 2023

v0.0.21

Nov 15, 2023

v0.0.20

Nov 15, 2023

v0.0.19

Nov 15, 2023

v0.0.18

Nov 15, 2023

v0.0.17

Nov 13, 2023

v0.0.16

Nov 8, 2023

v0.0.15

Nov 6, 2023

v0.0.14

Nov 6, 2023

v0.0.13

Nov 6, 2023

v0.0.12

Nov 3, 2023

v0.0.11

Nov 3, 2023

v0.0.10

Nov 3, 2023

v0.0.9

Nov 3, 2023

v0.0.8

Oct 31, 2023

Changes in this version

type Options

+ CommitSubscriber types.Subscriber[proto.ChangelogEntry]

v0.0.7

Oct 26, 2023

v0.0.6

Oct 26, 2023

v0.0.5

Oct 24, 2023

v0.0.4

Oct 23, 2023

Changes in this version

type MultiTree

+ func (t *MultiTree) Catchup(rlogManager *rlog.Manager, endVersion int64) error

type Options

+ ExportNonSnapshotVersion bool

+ SdkBackwardCompatible bool

v0.0.3

Oct 13, 2023

v0.0.2

Oct 11, 2023

Changes in this version

+ const DefaultSnapshotInterval

+ const DefaultSnapshotWriterLimit

+ const FileNameKVs

+ const FileNameLeaves

+ const FileNameMetadata

+ const FileNameNodes

+ const LockFileName

+ const MetadataFileName

+ const OffsetHash

+ const OffsetHeight

+ const OffsetKeyLeaf

+ const OffsetLeafHash

+ const OffsetLeafKeyLen

+ const OffsetLeafKeyOffset

+ const OffsetLeafVersion

+ const OffsetPreTrees

+ const OffsetSize

+ const OffsetVersion

+ const SizeHash

+ const SizeLeaf

+ const SizeLeafWithoutHash

+ const SizeMetadata

+ const SizeNode

+ const SizeNodeWithoutHash

+ const SnapshotDirLen

+ const SnapshotFileMagic

+ const SnapshotFormat

+ const SnapshotPrefix

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

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

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

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

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

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

+ var ErrorExportDone = errors.New("export is complete")

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

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

+ func HashNode(node Node) []byte

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

+ func NewCache(cacheSize int) cache.Cache

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

+ func VerifyHash(node Node) bool

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

+ type CommitID struct

+ Hash []byte

+ Version int64

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

+ func (*CommitID) ProtoMessage()

+ func (cid CommitID) String() string

+ func (m *CommitID) GetHash() []byte

+ func (m *CommitID) GetVersion() int64

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

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

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

+ func (m *CommitID) Reset()

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

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

+ func (m *CommitID) XXX_DiscardUnknown()

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

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

+ func (m *CommitID) XXX_Size() int

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

+ type CommitInfo struct

+ StoreInfos []StoreInfo

+ Version int64

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

+ func (*CommitInfo) ProtoMessage()

+ func (m *CommitInfo) GetStoreInfos() []StoreInfo

+ func (m *CommitInfo) GetVersion() int64

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

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

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

+ func (m *CommitInfo) Reset()

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

+ func (m *CommitInfo) String() string

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

+ func (m *CommitInfo) XXX_DiscardUnknown()

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

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

+ func (m *CommitInfo) XXX_Size() int

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

+ type DB struct

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

+ func (db *DB) ApplyChangeSet(name string, changeSet iavl.ChangeSet) error

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

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

+ func (db *DB) Close() error

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

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

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

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

+ func (db *DB) ReadOnly() bool

+ func (db *DB) Reload() error

+ func (db *DB) RewriteSnapshot() error

+ func (db *DB) RewriteSnapshotBackground() error

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

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

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

+ func (db *DB) UpdateCommitInfo()

+ func (db *DB) Version() int64

+ func (db *DB) WaitAsyncCommit() error

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

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

+ type ExportNode struct

+ Height int8

+ Key []byte

+ Value []byte

+ Version int64

+ type Exporter struct

+ func (e *Exporter) Close()

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

+ type FileLock interface

+ Unlock func() error

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

+ type Iterator struct

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

+ 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 Logger interface

+ Debug func(msg string, keyvals ...interface{})

+ Error func(msg string, keyvals ...interface{})

+ Info func(msg string, keyvals ...interface{})

+ func NewNopLogger() Logger

+ type MemNode struct

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

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

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

+ func (node *MemNode) Height() uint8

+ func (node *MemNode) IsLeaf() bool

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

+ func (node *MemNode) Left() Node

+ func (node *MemNode) Mutate(version, cowVersion uint32) *MemNode

+ func (node *MemNode) Right() Node

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

+ func (node *MemNode) Size() int64

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

+ func (node *MemNode) Version() uint32

+ type MmapFile struct

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

+ func (m *MmapFile) Close() error

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

+ type MultiTree struct

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

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

+ func (t *MultiTree) ApplyChangeSet(name string, changeSet iavl.ChangeSet) error

+ func (t *MultiTree) ApplyChangeSets(changeSets []*NamedChangeSet) 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) LastCommitInfo() *CommitInfo

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

+ 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) Trees() []NamedTree

+ func (t *MultiTree) UpdateCommitInfo()

+ func (t *MultiTree) Version() int64

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

+ func (t *MultiTree) WriteSnapshot(dir string, wp *pond.WorkerPool) error

+ type MultiTreeExporter struct

+ func NewMultiTreeExporter(dir string, version uint32, supportExportNonSnapshotVersion bool) (exporter *MultiTreeExporter, err error)

+ func (mte *MultiTreeExporter) Close() error

+ func (mte *MultiTreeExporter) Next() (interface{}, error)

+ type MultiTreeImporter struct

+ func NewMultiTreeImporter(dir string, height uint64) (*MultiTreeImporter, error)

+ func (mti *MultiTreeImporter) Add(item interface{}) error

+ func (mti *MultiTreeImporter) AddNode(node *ExportNode)

+ func (mti *MultiTreeImporter) AddTree(name string) error

+ func (mti *MultiTreeImporter) Close() error

+ func (mti *MultiTreeImporter) Finalize() error

+ type MultiTreeMetadata struct

+ CommitInfo *CommitInfo

+ InitialVersion int64

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

+ func (*MultiTreeMetadata) ProtoMessage()

+ func (m *MultiTreeMetadata) GetCommitInfo() *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 NamedTree struct

+ Name string

+ type Node interface

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

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

+ Hash func() []byte

+ Height func() uint8

+ IsLeaf func() bool

+ Key func() []byte

+ Left func() Node

+ Mutate func(version, cowVersion uint32) *MemNode

+ Right func() Node

+ SafeHash func() []byte

+ Size func() int64

+ Value func() []byte

+ Version func() uint32

+ 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

+ LoadForOverwriting bool

+ Logger Logger

+ ReadOnly bool

+ SnapshotInterval uint32

+ SnapshotKeepRecent uint32

+ SnapshotWriterLimit int

+ TargetVersion uint32

+ TriggerStateSyncExport func(height int64)

+ ZeroCopy bool

+ func (opts *Options) FillDefaults()

+ func (opts Options) Validate() error

+ type PersistedNode struct

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

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

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

+ func (node PersistedNode) Height() uint8

+ func (node PersistedNode) IsLeaf() bool

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

+ func (node PersistedNode) Left() Node

+ func (node PersistedNode) Mutate(version, _ uint32) *MemNode

+ func (node PersistedNode) Right() Node

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

+ func (node PersistedNode) Size() int64

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

+ func (node PersistedNode) Version() uint32

+ type Snapshot struct

+ func NewEmptySnapshot(version uint32) *Snapshot

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

+ func (snapshot *Snapshot) Close() error

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

+ 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) Node(index uint32) PersistedNode

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

+ func (snapshot *Snapshot) RootNode() PersistedNode

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

+ func (snapshot *Snapshot) Version() uint32

+ type StoreInfo struct

+ CommitId CommitID

+ Name string

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

+ func (*StoreInfo) ProtoMessage()

+ func (m *StoreInfo) GetCommitId() CommitID

+ func (m *StoreInfo) GetName() string

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

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

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

+ func (m *StoreInfo) Reset()

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

+ func (m *StoreInfo) String() string

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

+ func (m *StoreInfo) XXX_DiscardUnknown()

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

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

+ func (m *StoreInfo) XXX_Size() int

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

+ type Tree struct

+ func New(cacheSize int) *Tree

+ func NewEmptyTree(version uint64, initialVersion uint32, cacheSize int) *Tree

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

+ func NewWithInitialVersion(initialVersion uint32, cacheSize int) *Tree

+ func (t *Tree) ApplyChangeSet(changeSet iavl.ChangeSet)

+ 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) *Iterator

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

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

+ 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

+ func (t *Tree) Version() int64

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

+ type TreeImporter struct

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

+ func (ai *TreeImporter) Add(node *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