rootmulti

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 19, 2024 License: Apache-2.0, Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const ProofOpMultiStore = "multistore"

the multi-store proof operation constant value

Variables

View Source 
var (
	IgPruneHeightsLen = false
)

Functions

func DefaultProofRuntime 

func DefaultProofRuntime() (prt *merkle.ProofRuntime)

XXX: This should be managed by the rootMultiStore which may want to register more proof ops?

func GetLatestStoredMptHeight 

func GetLatestStoredMptHeight() uint64

GetLatestStoredMptHeight get latest mpt storage height

func GetPruningHeights 

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

func MultiStoreProofOpDecoder 

func MultiStoreProofOpDecoder(pop merkle.ProofOp) (merkle.ProofOperator, error)

MultiStoreProofOpDecoder returns a multi-store merkle proof operator from a given proof operation.

func RequireProof 

func RequireProof(subpath string) bool

RequireProof returns whether proof is required for the subpath.

func SetPruningHeights 

func SetPruningHeights(db dbm.DB, pruneHeights []int64)

Types

type MultiStoreProof 

type MultiStoreProof struct {
	StoreInfos []storeInfo
}

MultiStoreProof defines a collection of store proofs in a multi-store

func NewMultiStoreProof 

func NewMultiStoreProof(storeInfos []storeInfo) *MultiStoreProof

func (*MultiStoreProof) ComputeRootHash 

func (proof *MultiStoreProof) ComputeRootHash() []byte

ComputeRootHash returns the root hash for a given multi-store proof.

type MultiStoreProofOp 

type MultiStoreProofOp struct {

	// To encode in ProofOp.Data.
	Proof *MultiStoreProof `json:"proof"`
	// contains filtered or unexported fields
}

TODO: document

func NewMultiStoreProofOp 

func NewMultiStoreProofOp(key []byte, proof *MultiStoreProof) MultiStoreProofOp

func (MultiStoreProofOp) GetKey 

func (op MultiStoreProofOp) GetKey() []byte

GetKey returns the key for a multi-store proof operation.

func (MultiStoreProofOp) ProofOp 

func (op MultiStoreProofOp) ProofOp() merkle.ProofOp

ProofOp return a merkle proof operation from a given multi-store proof operation.

func (MultiStoreProofOp) Run 

func (op MultiStoreProofOp) Run(args [][]byte) ([][]byte, error)

Run executes a multi-store proof operation for a given value. It returns the root hash if the value matches all the store's commitID's hash or an error otherwise.

func (MultiStoreProofOp) String 

func (op MultiStoreProofOp) String() string

String implements the Stringer interface for a mult-store proof operation.

type Store 

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

Store is composed of many CommitStores. Name contrasts with cacheMultiStore which is for cache-wrapping other MultiStores. It implements the CommitMultiStore interface.

func NewStore 

func NewStore(db dbm.DB) *Store

NewStore returns a reference to a new Store object with the provided DB. The store will be created with a PruneNothing pruning strategy by default. After a store is created, KVStores must be mounted and finally LoadLatestVersion or LoadVersion must be called.

func (*Store) AppendCommitFilters 

func (rs *Store) AppendCommitFilters(filters []storetypes.StoreFilter)

func (*Store) AppendPruneFilters 

func (rs *Store) AppendPruneFilters(filters []storetypes.StoreFilter)

func (*Store) AppendVersionFilters 

func (rs *Store) AppendVersionFilters(filters []storetypes.VersionFilter)

func (*Store) CacheMultiStore 

func (rs *Store) CacheMultiStore() types.CacheMultiStore

CacheMultiStore cache-wraps the multi-store and returns a CacheMultiStore. It implements the MultiStore interface.

func (*Store) CacheMultiStoreWithVersion 

func (rs *Store) CacheMultiStoreWithVersion(version int64) (types.CacheMultiStore, error)

CacheMultiStoreWithVersion is analogous to CacheMultiStore except that it attempts to load stores at a given version (height). An error is returned if any store cannot be loaded. This should only be used for querying and iterating at past heights.

func (*Store) CacheWrap 

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

Implements CacheWrapper/Store/CommitStore.

func (*Store) CacheWrapWithTrace 

func (rs *Store) CacheWrapWithTrace(_ io.Writer, _ types.TraceContext) types.CacheWrap

CacheWrapWithTrace implements the CacheWrapper interface.

func (*Store) CleanBrcRpcState 

func (rs *Store) CleanBrcRpcState()

func (*Store) CommitterCommit 

func (rs *Store) CommitterCommit(interface{}) (_ types.CommitID, _ interface{})

func (*Store) CommitterCommitMap 

func (rs *Store) CommitterCommitMap(inputDeltaMap *tmtypes.TreeDelta) (types.CommitID, *tmtypes.TreeDelta)

Implements Committer/CommitStore.

func (Store) Copy 

func (src Store) Copy() *Store

func (*Store) CurrentVersion 

func (rs *Store) CurrentVersion() int64

func (*Store) Export 

func (rs *Store) Export(to *Store, initVersion int64) error

Snapshot implements snapshottypes.Snapshotter. The snapshot output for a given format must be identical across nodes such that chunks from different sources fit together. If the output for a given format changes (at the byte level), the snapshot format must be bumped - see TestMultistoreSnapshot_Checksum test.

func (*Store) FlushPruneHeights 

func (rs *Store) FlushPruneHeights(pruneHeights []int64, versions []int64)

func (*Store) GetCommitKVStore 

func (rs *Store) GetCommitKVStore(key types.StoreKey) types.CommitKVStore

GetCommitKVStore returns a mounted CommitKVStore for a given StoreKey. If the store is wrapped in an inter-block cache, it will be unwrapped before returning.

func (*Store) GetCommitStore 

func (rs *Store) GetCommitStore(key types.StoreKey) types.CommitStore

GetCommitStore returns a mounted CommitStore for a given StoreKey. If the store is wrapped in an inter-block cache, it will be unwrapped before returning.

func (*Store) GetCommitVersion 

func (rs *Store) GetCommitVersion() (int64, error)

func (*Store) GetDBReadCount 

func (rs *Store) GetDBReadCount() int

func (*Store) GetDBReadTime 

func (rs *Store) GetDBReadTime() int

func (*Store) GetDBWriteCount 

func (rs *Store) GetDBWriteCount() int

func (*Store) GetFlatKVReadCount 

func (rs *Store) GetFlatKVReadCount() int

func (*Store) GetFlatKVReadTime 

func (rs *Store) GetFlatKVReadTime() int

func (*Store) GetFlatKVWriteCount 

func (rs *Store) GetFlatKVWriteCount() int

func (*Store) GetFlatKVWriteTime 

func (rs *Store) GetFlatKVWriteTime() int

func (*Store) GetKVStore 

func (rs *Store) GetKVStore(key types.StoreKey) types.KVStore

GetKVStore returns a mounted KVStore for a given StoreKey. If tracing is enabled on the KVStore, a wrapped TraceKVStore will be returned with the root store's tracer, otherwise, the original KVStore will be returned.

NOTE: The returned KVStore may be wrapped in an inter-block cache if it is set on the root store.

func (*Store) GetLatestVersion 

func (rs *Store) GetLatestVersion() int64

func (*Store) GetNodeReadCount 

func (rs *Store) GetNodeReadCount() int

func (*Store) GetPruningHeights 

func (rs *Store) GetPruningHeights() []int64

func (*Store) GetStore 

func (rs *Store) GetStore(key types.StoreKey) types.Store

GetStore returns a mounted Store for a given StoreKey. If the StoreKey does not exist, it will panic. If the Store is wrapped in an inter-block cache, it will be unwrapped prior to being returned.

TODO: This isn't used directly upstream. Consider returning the Store as-is instead of unwrapping.

func (*Store) GetStoreName 

func (rs *Store) GetStoreName() string

func (*Store) GetStoreType 

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

Implements Store.

func (*Store) GetStores 

func (rs *Store) GetStores() map[types.StoreKey]types.CommitKVStore

func (*Store) GetVersions 

func (rs *Store) GetVersions() []int64

func (*Store) LastCommitID 

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

Implements Committer/CommitStore.

func (*Store) LastCommitVersion 

func (rs *Store) LastCommitVersion() int64

func (*Store) LoadLatestVersion 

func (rs *Store) LoadLatestVersion() error

LoadLatestVersion implements CommitMultiStore.

func (*Store) LoadLatestVersionAndUpgrade 

func (rs *Store) LoadLatestVersionAndUpgrade(upgrades *types.StoreUpgrades) error

LoadLatestVersionAndUpgrade implements CommitMultiStore

func (*Store) LoadVersion 

func (rs *Store) LoadVersion(ver int64) error

LoadVersion implements CommitMultiStore.

func (*Store) LoadVersionAndUpgrade 

func (rs *Store) LoadVersionAndUpgrade(ver int64, upgrades *types.StoreUpgrades) error

LoadVersionAndUpgrade allows us to rename substores while loading an older version

func (*Store) MountStoreWithDB 

func (rs *Store) MountStoreWithDB(key types.StoreKey, typ types.StoreType, db dbm.DB)

Implements CommitMultiStore.

func (*Store) Query 

func (rs *Store) Query(req abci.RequestQuery) abci.ResponseQuery

Query calls substore.Query with the same `req` where `req.Path` is modified to remove the substore prefix. Ie. `req.Path` here is `/<substore>/<path>`, and trimmed to `/<path>` for the substore. TODO: add proof for `multistore -> substore`.

func (*Store) ResetCount 

func (rs *Store) ResetCount()

func (*Store) SetInterBlockCache 

func (rs *Store) SetInterBlockCache(c types.MultiStorePersistentCache)

SetInterBlockCache sets the Store's internal inter-block (persistent) cache. When this is defined, all CommitKVStores will be wrapped with their respective inter-block cache.

func (*Store) SetLazyLoading 

func (rs *Store) SetLazyLoading(lazyLoading bool)

SetLazyLoading sets if the iavl store should be loaded lazily or not

func (*Store) SetLogger 

func (rs *Store) SetLogger(log tmlog.Logger)

func (*Store) SetPruning 

func (rs *Store) SetPruning(pruningOpts types.PruningOptions)

SetPruning sets the pruning strategy on the root store and all the sub-stores. Note, calling SetPruning on the root store prior to LoadVersion or LoadLatestVersion performs a no-op as the stores aren't mounted yet.

func (*Store) SetTracer 

func (rs *Store) SetTracer(w io.Writer) types.MultiStore

SetTracer sets the tracer for the MultiStore that the underlying stores will utilize to trace operations. A MultiStore is returned.

func (*Store) SetTracingContext 

func (rs *Store) SetTracingContext(tc types.TraceContext) types.MultiStore

SetTracingContext updates the tracing context for the MultiStore by merging the given context with the existing context by key. Any existing keys will be overwritten. It is implied that the caller should update the context when necessary between tracing operations. It returns a modified MultiStore.

func (*Store) SetUpgradeVersion 

func (rs *Store) SetUpgradeVersion(version int64)

func (*Store) StopStore 

func (rs *Store) StopStore()

func (*Store) TracingEnabled 

func (rs *Store) TracingEnabled() bool

TracingEnabled returns if tracing is enabled for the MultiStore.

type StoreSort 

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

type StoreSorts 

type StoreSorts []StoreSort

func (StoreSorts) Len 

func (s StoreSorts) Len() int

func (StoreSorts) Less 

func (s StoreSorts) Less(i, j int) bool

func (StoreSorts) Swap 

func (s StoreSorts) Swap(i, j int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.