Versions in this module Expand all Collapse all v0 v0.1.0 Jan 19, 2024 Changes in this version + const FlagLoadVersionAsync + const GasDeleteDesc + const GasHasDesc + const GasIterNextCostFlatDesc + const GasReadCostFlatDesc + const GasReadPerByteDesc + const GasValuePerByteDesc + const GasWriteCostFlatDesc + const GasWritePerByteDesc + const ProofOpIAVLCommitment + const ProofOpSimpleMerkleCommitment + const PruningOptionCustom + const PruningOptionDefault + const PruningOptionEverything + const PruningOptionNothing + const StoreCodespace + var ErrIntOverflowCommitInfo = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowListening = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowProof = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthCommitInfo = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthListening = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthProof = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidProof = sdkerrors.Register(StoreCodespace, 2, "invalid proof") + var ErrUnexpectedEndOfGroupCommitInfo = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupListening = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupProof = fmt.Errorf("proto: unexpected end of group") + var PruneDefault = NewPruningOptions(100, 10000, 10, 200) + var PruneEverything = NewPruningOptions(5, 0, 10, 5) + var PruneNothing = NewPruningOptions(0, 1, 0, 1<<64 - 1) + func AsDefaultGasConfig(gc *GasConfig) + func AssertValidKey(key []byte) + func AssertValidValue(value []byte) + func ClearMsRWSet(m MsRWSet) + func CommitmentOpDecoder(pop merkle.ProofOp) (merkle.ProofOperator, error) + func Cp(bz []byte) (ret []byte) + func DiffKVStores(a KVStore, b KVStore, prefixesToSkip [][]byte) (kvAs, kvBs []tmkv.Pair) + func InclusiveEndBytes(inclusiveBytes []byte) []byte + func PrefixEndBytes(prefix []byte) []byte + func RevertSnapshotWSet(store KVStore, set SnapshotWSet) + func UpdateGlobalGasConfig(gc *GasConfig) + type Analyser interface + GetDBReadCount func() int + GetDBReadTime func() int + GetDBWriteCount func() int + GetFlatKVReadCount func() int + GetFlatKVReadTime func() int + GetFlatKVWriteCount func() int + GetFlatKVWriteTime func() int + GetNodeReadCount func() int + ResetCount func() + type CacheKVRWSet struct + Read map[string][]byte + Write map[string]DirtyValue + func NewCacheKvRWSet() CacheKVRWSet + type CacheKVStore interface + RevertDBWithSnapshotRWSet func(set SnapshotWSet) + Write func() + WriteWithSnapshotWSet func() SnapshotWSet + type CacheManager interface + Clear func() + DisableCacheReadList func() + GetRWSet func(set MsRWSet) + IteratorCache func(isdirty bool, ...) bool + type CacheMultiStore interface + RevertDBWithMultiSnapshotRWSet func(set MultiSnapshotWSet) + Write func() + WriteGetMultiSnapshotWSet func() MultiSnapshotWSet + type CacheMultiStoreResetter interface + Reset func(MultiStore) bool + type CacheWrap interface + CacheWrap func() CacheWrap + CacheWrapWithTrace func(w io.Writer, tc TraceContext) CacheWrap + RevertDBWithSnapshotRWSet func(set SnapshotWSet) + Write func() + WriteWithSnapshotWSet func() SnapshotWSet + type CacheWrapper interface + CacheWrap func() CacheWrap + CacheWrapWithTrace func(w io.Writer, tc TraceContext) CacheWrap + type CommitID struct + Hash []byte + Version int64 + func (*CommitID) Descriptor() ([]byte, []int) + func (*CommitID) ProtoMessage() + func (cid CommitID) IsZero() bool + 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 (ci CommitInfo) CommitID() CommitID + func (ci CommitInfo) Hash() []byte + func (ci CommitInfo) ProofOp(storeName string) merkle.ProofOp + 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 CommitKVStore interface + type CommitMultiStore interface + CleanBrcRpcState func() + CommitterCommitMap func(*types.TreeDelta) (CommitID, *types.TreeDelta) + GetCommitKVStore func(key StoreKey) CommitKVStore + GetCommitStore func(key StoreKey) CommitStore + GetCommitVersion func() (int64, error) + LoadLatestVersion func() error + LoadLatestVersionAndUpgrade func(upgrades *StoreUpgrades) error + LoadVersion func(ver int64) error + LoadVersionAndUpgrade func(ver int64, upgrades *StoreUpgrades) error + MountStoreWithDB func(key StoreKey, typ StoreType, db dbm.DB) + SetInterBlockCache func(MultiStorePersistentCache) + SetLogger func(log log.Logger) + StopStore func() + type CommitMultiStorePipeline interface + AppendCommitFilters func(filters []StoreFilter) + AppendPruneFilters func(filters []StoreFilter) + AppendVersionFilters func(filters []VersionFilter) + type CommitStore interface + type CommitmentOp struct + Key []byte + Proof *ics23.CommitmentProof + Spec *ics23.ProofSpec + Type string + func NewIavlCommitmentOp(key []byte, proof *ics23.CommitmentProof) CommitmentOp + func NewSimpleMerkleCommitmentOp(key []byte, proof *ics23.CommitmentProof) CommitmentOp + func (op CommitmentOp) GetKey() []byte + func (op CommitmentOp) ProofOp() merkle.ProofOp + func (op CommitmentOp) Run(args [][]byte) ([][]byte, error) + type Committer interface + CommitterCommit func(interface{}) (CommitID, interface{}) + LastCommitID func() CommitID + LastCommitVersion func() int64 + SetPruning func(PruningOptions) + SetUpgradeVersion func(int64) + type DirtyValue struct + Deleted bool + Value []byte + type ErrorGasOverflow struct + Descriptor string + type ErrorOutOfGas struct + Descriptor string + type Gas = uint64 + type GasConfig struct + DeleteCost Gas + HasCost Gas + IterNextCostFlat Gas + ReadCostFlat Gas + ReadCostPerByte Gas + WriteCostFlat Gas + WriteCostPerByte Gas + func GetDefaultGasConfig() *GasConfig + func GetGlobalGasConfig() GasConfig + func KVGasConfig() GasConfig + func TransientGasConfig() GasConfig + type GasMeter interface + ConsumeGas func(amount Gas, descriptor string) + GasConsumed func() Gas + GasConsumedToLimit func() Gas + IsOutOfGas func() bool + IsPastLimit func() bool + Limit func() Gas + SetGas func(val Gas) + func NewGasMeter(limit Gas) GasMeter + func NewInfiniteGasMeter() GasMeter + type Iterator = dbm.Iterator + func KVStorePrefixIterator(kvs KVStore, prefix []byte) Iterator + func KVStorePrefixIteratorPaginated(kvs KVStore, prefix []byte, page, limit uint) Iterator + func KVStoreReversePrefixIterator(kvs KVStore, prefix []byte) Iterator + func KVStoreReversePrefixIteratorPaginated(kvs KVStore, prefix []byte, page, limit uint) Iterator + type KVPair tmkv.Pair + type KVStore interface + CleanBrcRpcState func() + Delete func(key []byte) + Get func(key []byte) []byte + Has func(key []byte) bool + Iterator func(start, end []byte) Iterator + ReverseIterator func(start, end []byte) Iterator + Set func(key, value []byte) + type KVStoreKey struct + func NewKVStoreKey(name string) *KVStoreKey + func (key *KVStoreKey) Name() string + func (key *KVStoreKey) String() string + type MemoryStoreKey struct + func NewMemoryStoreKey(name string) *MemoryStoreKey + func (key *MemoryStoreKey) Name() string + func (key *MemoryStoreKey) String() string + type MsRWSet = map[StoreKey]CacheKVRWSet + type MultiSnapshotWSet struct + Root SnapshotWSet + Stores map[StoreKey]SnapshotWSet + func NewMultiSnapshotWSet() MultiSnapshotWSet + type MultiStore interface + CacheMultiStore func() CacheMultiStore + CacheMultiStoreWithVersion func(version int64) (CacheMultiStore, error) + GetKVStore func(StoreKey) KVStore + GetStore func(StoreKey) Store + SetTracer func(w io.Writer) MultiStore + SetTracingContext func(TraceContext) MultiStore + TracingEnabled func() bool + type MultiStorePersistentCache interface + GetStoreCache func(key StoreKey, store CommitKVStore) CommitKVStore + Reset func() + Unwrap func(key StoreKey) CommitKVStore + type PaginatedIterator struct + func (pi *PaginatedIterator) Next() + func (pi *PaginatedIterator) Valid() bool + type PruningOptions struct + Interval uint64 + KeepEvery uint64 + KeepRecent uint64 + MaxRetainNum uint64 + func NewPruningOptions(keepRecent, keepEvery, interval, maxRetainNum uint64) PruningOptions + func NewPruningOptionsFromString(strategy string) PruningOptions + func (po PruningOptions) Validate() error + type Queryable interface + Query func(abci.RequestQuery) abci.ResponseQuery + type ReusableGasMeter interface + Reset func() + func NewReusableInfiniteGasMeter() ReusableGasMeter + type RevertWriteChange struct + PrevValue []byte + type SnapshotWSet struct + Write map[string]RevertWriteChange + func NewSnapShotWSet() SnapshotWSet + type Store interface + GetStoreName func() string + GetStoreType func() StoreType + type StoreFilter func(module string, h int64, store CommitKVStore) bool + 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 + func (si StoreInfo) GetHash() []byte + type StoreKVPair struct + Delete bool + Key []byte + StoreKey string + Value []byte + func (*StoreKVPair) Descriptor() ([]byte, []int) + func (*StoreKVPair) ProtoMessage() + func (m *StoreKVPair) GetDelete() bool + func (m *StoreKVPair) GetKey() []byte + func (m *StoreKVPair) GetStoreKey() string + func (m *StoreKVPair) GetValue() []byte + func (m *StoreKVPair) Marshal() (dAtA []byte, err error) + func (m *StoreKVPair) MarshalTo(dAtA []byte) (int, error) + func (m *StoreKVPair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StoreKVPair) Reset() + func (m *StoreKVPair) Size() (n int) + func (m *StoreKVPair) String() string + func (m *StoreKVPair) Unmarshal(dAtA []byte) error + func (m *StoreKVPair) XXX_DiscardUnknown() + func (m *StoreKVPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StoreKVPair) XXX_Merge(src proto.Message) + func (m *StoreKVPair) XXX_Size() int + func (m *StoreKVPair) XXX_Unmarshal(b []byte) error + type StoreKVPairWriteListener struct + func NewStoreKVPairWriteListener(w io.Writer, m *codec.CodecProxy) *StoreKVPairWriteListener + func (wl *StoreKVPairWriteListener) OnWrite(storeKey StoreKey, key []byte, value []byte, delete bool) error + type StoreKey interface + Name func() string + String func() string + type StoreRename struct + NewKey string + OldKey string + type StoreType int + const StoreTypeDB + const StoreTypeIAVL + const StoreTypeMPT + const StoreTypeMemory + const StoreTypeMulti + const StoreTypeTransient + type StoreUpgrades struct + Added []string + Deleted []string + Renamed []StoreRename + func (s *StoreUpgrades) IsAdded(key string) bool + func (s *StoreUpgrades) IsDeleted(key string) bool + func (s *StoreUpgrades) RenamedFrom(key string) string + type TraceContext map[string]interface + type TransientStoreKey struct + func NewTransientStoreKey(name string) *TransientStoreKey + func (key *TransientStoreKey) Name() string + func (key *TransientStoreKey) String() string + type VersionCallback = func(name string, version int64) + type VersionFilter func(h int64) func(callback VersionCallback) + type WriteListener interface + OnWrite func(storeKey StoreKey, key []byte, value []byte, delete bool) error