iavl

Documentation

Index

• Variables
• func GetCommitVersions(db dbm.DB) ([]int64, error)
• func HasVersion(db dbm.DB, version int64) (bool, error)
• func LoadStore(db dbm.DB, flatKVDB dbm.DB, id types.CommitID, lazyLoading bool, ...) (types.CommitKVStore, error)
• func LoadStoreWithInitialVersion(db dbm.DB, flatKVDB dbm.DB, id types.CommitID, lazyLoading bool, ...) (types.CommitKVStore, error)
• type Store
  • func UnsafeNewStore(tree *iavl.MutableTree) *Store
  • func (st *Store) CacheWrap() types.CacheWrap
  • func (st *Store) CacheWrapWithTrace(w io.Writer, tc types.TraceContext) types.CacheWrap
  • func (st *Store) CommitterCommit(inputDelta interface{}) (types.CommitID, interface{})
  • func (st *Store) CurrentVersion() int64
  • func (st *Store) Delete(key []byte)
  • func (st *Store) DeleteVersions(versions ...int64) error
  • func (st *Store) Export(version int64) (*iavl.Exporter, error)
  • func (st *Store) Get(key []byte) []byte
  • func (st *Store) GetDBReadCount() int
  • func (st *Store) GetDBReadTime() int
  • func (st *Store) GetDBWriteCount() int
  • func (st *Store) GetEmptyImmutable() *Store
  • func (st *Store) GetFlatKVReadCount() int
  • func (st *Store) GetFlatKVReadTime() int
  • func (st *Store) GetFlatKVWriteCount() int
  • func (st *Store) GetFlatKVWriteTime() int
  • func (st *Store) GetHeights() map[int64][]byte
  • func (st *Store) GetImmutable(version int64) (*Store, error)
  • func (st *Store) GetNodeReadCount() int
  • func (st *Store) GetStoreType() types.StoreType
  • func (st *Store) GetUpgradeVersion() int64
  • func (st *Store) Has(key []byte) (exists bool)
  • func (st *Store) Import(version int64) (*iavl.Importer, error)
  • func (st *Store) Iterator(start, end []byte) types.Iterator
  • func (st *Store) LastCommitID() types.CommitID
  • func (st *Store) LastCommitVersion() int64
  • func (st *Store) Query(req abci.RequestQuery) (res abci.ResponseQuery)
  • func (st *Store) ResetCount()
  • func (st *Store) ReverseIterator(start, end []byte) types.Iterator
  • func (st *Store) Set(key, value []byte)
  • func (st *Store) SetInitialVersion(version int64)
  • func (st *Store) SetPruning(_ types.PruningOptions)
  • func (st *Store) SetUpgradeVersion(version int64)
  • func (st *Store) StopStore()
  • func (st *Store) StopStoreWithVersion(version int64)
  • func (st *Store) ValidateFlatVersion() error
  • func (st *Store) VersionExists(version int64) bool
• type Tree

Variables

var (
	FlagIavlCacheSize = "iavl-cache-size"

	IavlCacheSize = 1000000
)

Functions

func GetCommitVersions

func GetCommitVersions(db dbm.DB) ([]int64, error)

func HasVersion

func HasVersion(db dbm.DB, version int64) (bool, error)

func LoadStore

func LoadStore(db dbm.DB, flatKVDB dbm.DB, id types.CommitID, lazyLoading bool, startVersion int64) (types.CommitKVStore, error)

LoadStore returns an IAVL Store as a CommitKVStore. Internally, it will load the store's version (id) from the provided DB. An error is returned if the version fails to load.

func LoadStoreWithInitialVersion

func LoadStoreWithInitialVersion(db dbm.DB, flatKVDB dbm.DB, id types.CommitID, lazyLoading bool, initialVersion uint64, upgradeVersion uint64) (types.CommitKVStore, error)

LoadStoreWithInitialVersion returns an IAVL Store as a CommitKVStore setting its initialVersion to the one given. Internally, it will load the store's version (id) from the provided DB. An error is returned if the version fails to load.

Types

type Store

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

Store Implements types.KVStore and CommitKVStore.

func UnsafeNewStore

func UnsafeNewStore(tree *iavl.MutableTree) *Store

UnsafeNewStore returns a reference to a new IAVL Store with a given mutable IAVL tree reference. It should only be used for testing purposes.

CONTRACT: The IAVL tree should be fully loaded. CONTRACT: PruningOptions passed in as argument must be the same as pruning options passed into iavl.MutableTree

func (*Store) CacheWrap

func (st *Store) CacheWrap() types.CacheWrap

Implements Store.

func (*Store) CacheWrapWithTrace

func (st *Store) CacheWrapWithTrace(w io.Writer, tc types.TraceContext) types.CacheWrap

CacheWrapWithTrace implements the Store interface.

func (*Store) CommitterCommit

func (st *Store) CommitterCommit(inputDelta interface{}) (types.CommitID, interface{})

func (*Store) CurrentVersion

func (st *Store) CurrentVersion() int64

func (*Store) Delete

func (st *Store) Delete(key []byte)

Implements types.KVStore.

func (*Store) DeleteVersions

func (st *Store) DeleteVersions(versions ...int64) error

DeleteVersions deletes a series of versions from the MutableTree. An error is returned if any single version is invalid or the delete fails. All writes happen in a single batch with a single commit.

func (*Store) Export

func (st *Store) Export(version int64) (*iavl.Exporter, error)

Exports the IAVL store at the given version, returning an iavl.Exporter for the tree.

func (*Store) Get

func (st *Store) Get(key []byte) []byte

Implements types.KVStore.

func (*Store) GetDBReadCount

func (st *Store) GetDBReadCount() int

func (*Store) GetDBReadTime

func (st *Store) GetDBReadTime() int

func (*Store) GetDBWriteCount

func (st *Store) GetDBWriteCount() int

func (*Store) GetEmptyImmutable

func (st *Store) GetEmptyImmutable() *Store

GetEmptyImmutable returns an empty immutable IAVL tree

func (*Store) GetFlatKVReadCount

func (st *Store) GetFlatKVReadCount() int

func (*Store) GetFlatKVReadTime

func (st *Store) GetFlatKVReadTime() int

func (*Store) GetFlatKVWriteCount

func (st *Store) GetFlatKVWriteCount() int

func (*Store) GetFlatKVWriteTime

func (st *Store) GetFlatKVWriteTime() int

func (*Store) GetHeights

func (st *Store) GetHeights() map[int64][]byte

func (*Store) GetImmutable

func (st *Store) GetImmutable(version int64) (*Store, error)

GetImmutable returns a reference to a new store backed by an immutable IAVL tree at a specific version (height) without any pruning options. This should be used for querying and iteration only. If the version does not exist or has been pruned, an empty immutable IAVL tree will be used. Any mutable operations executed will result in a panic.

func (*Store) GetNodeReadCount

func (st *Store) GetNodeReadCount() int

func (*Store) GetStoreType

func (st *Store) GetStoreType() types.StoreType

Implements Store.

func (*Store) GetUpgradeVersion

func (st *Store) GetUpgradeVersion() int64

func (*Store) Has

func (st *Store) Has(key []byte) (exists bool)

Implements types.KVStore.

func (*Store) Import

func (st *Store) Import(version int64) (*iavl.Importer, error)

Import imports an IAVL tree at the given version, returning an iavl.Importer for importing.

func (*Store) Iterator

func (st *Store) Iterator(start, end []byte) types.Iterator

Implements types.KVStore.

func (*Store) LastCommitID

func (st *Store) LastCommitID() types.CommitID

Implements Committer.

func (*Store) LastCommitVersion

func (st *Store) LastCommitVersion() int64

func (*Store) Query

func (st *Store) Query(req abci.RequestQuery) (res abci.ResponseQuery)

Query implements ABCI interface, allows queries

by default we will return from (latest height -1), as we will have merkle proofs immediately (header height = data height + 1) If latest-1 is not present, use latest (which must be present) if you care to have the latest data to see a tx results, you must explicitly set the height you want to see

func (*Store) ResetCount

func (st *Store) ResetCount()

func (*Store) ReverseIterator

func (st *Store) ReverseIterator(start, end []byte) types.Iterator

Implements types.KVStore.

func (*Store) Set

func (st *Store) Set(key, value []byte)

Implements types.KVStore.

func (*Store) SetInitialVersion

func (st *Store) SetInitialVersion(version int64)

SetInitialVersion sets the initial version of the IAVL tree. It is used when starting a new chain at an arbitrary height.

func (*Store) SetPruning

func (st *Store) SetPruning(_ types.PruningOptions)

SetPruning panics as pruning options should be provided at initialization since IAVl accepts pruning options directly.

func (*Store) SetUpgradeVersion

func (st *Store) SetUpgradeVersion(version int64)

func (*Store) StopStore

func (st *Store) StopStore()

func (*Store) StopStoreWithVersion

func (st *Store) StopStoreWithVersion(version int64)

func (*Store) ValidateFlatVersion

func (st *Store) ValidateFlatVersion() error

func (*Store) VersionExists

func (st *Store) VersionExists(version int64) bool

VersionExists returns whether or not a given version is stored.

type Tree

type Tree interface {
	Has(key []byte) bool
	Get(key []byte) (value []byte)
	Set(key, value []byte) bool
	Remove(key []byte) ([]byte, bool)
	PreChanges(keys []string, setOrDel []byte)
	SaveVersion(bool) ([]byte, int64, iavl.TreeDelta, error)
	GetModuleName() string
	GetDBWriteCount() int
	GetDBReadCount() int
	GetDBReadTime() int
	GetNodeReadCount() int
	ResetCount()
	DeleteVersion(version int64) error
	DeleteVersions(versions ...int64) error
	Version() int64
	Hash() []byte
	VersionExists(version int64) bool
	GetVersioned(key []byte, version int64) (int64, []byte)
	GetVersionedWithProof(key []byte, version int64) ([]byte, *iavl.RangeProof, error)
	GetImmutable(version int64) (*iavl.ImmutableTree, error)
	SetInitialVersion(version uint64)
	SetDelta(delta *iavl.TreeDelta)
	GetPersistedRoots() map[int64][]byte
	SetUpgradeVersion(int64)
}

Tree defines an interface that both mutable and immutable IAVL trees must implement. For mutable IAVL trees, the interface is directly implemented by an iavl.MutableTree. For an immutable IAVL tree, a wrapper must be made.