types

package

Go to main page

Versions in this module

v0

v0.48.86

Oct 24, 2023

v0.48.84

Oct 24, 2023

Changes in this version

+ const ProofOpIAVLCommitment

+ const ProofOpSMTCommitment

+ const ProofOpSimpleMerkleCommitment

+ const StoreCodespace

+ var ErrConflict = errors.Register(StoreCodespace, 6, "conflict")

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

+ var ErrIntOverflowListening = 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 ErrInvalidProof = errors.Register(StoreCodespace, 2, "invalid proof")

+ var ErrInvalidRequest = errors.Register(StoreCodespace, 7, "invalid request")

+ var ErrLogic = errors.Register(StoreCodespace, 5, "internal logic error")

+ var ErrTxDecode = errors.Register(StoreCodespace, 3, "tx parse error")

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

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

+ var ErrUnknownRequest = errors.Register(StoreCodespace, 4, "unknown request")

+ func BigEndianToUint64(bz []byte) uint64

+ func CommitmentOpDecoder(pop tmmerkle.ProofOp) (merkle.ProofOperator, error)

+ func NewKVStoreKeys(names ...string) map[string]*KVStoreKey

+ func ProofOpFromMap(cmap map[string][]byte, storeName string) (ret tmmerkle.ProofOp, err error)

+ func QueryResult(err error, debug bool) abci.ResponseQuery

+ func SliceContains(elements []T, v T) bool

+ func Uint64ToBigEndian(i uint64) []byte

+ type ABCIListener interface

+ ListenBeginBlock func(ctx context.Context, req abci.RequestBeginBlock, res abci.ResponseBeginBlock) error

+ ListenCommit func(ctx context.Context, res abci.ResponseCommit) error

+ ListenDeliverTx func(ctx context.Context, req abci.RequestDeliverTx, res abci.ResponseDeliverTx) error

+ ListenEndBlock func(ctx context.Context, req abci.RequestEndBlock, res abci.ResponseEndBlock) error

+ type BasicKVStore interface

+ Delete func(key []byte)

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

+ Has func(key []byte) bool

+ Set func(key, value []byte)

+ type BlockMetadata struct

+ DeliverTxs []*BlockMetadata_DeliverTx

+ RequestBeginBlock *types.RequestBeginBlock

+ RequestEndBlock *types.RequestEndBlock

+ ResponseBeginBlock *types.ResponseBeginBlock

+ ResponseCommit *types.ResponseCommit

+ ResponseEndBlock *types.ResponseEndBlock

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

+ func (*BlockMetadata) ProtoMessage()

+ func (m *BlockMetadata) GetDeliverTxs() []*BlockMetadata_DeliverTx

+ func (m *BlockMetadata) GetRequestBeginBlock() *types.RequestBeginBlock

+ func (m *BlockMetadata) GetRequestEndBlock() *types.RequestEndBlock

+ func (m *BlockMetadata) GetResponseBeginBlock() *types.ResponseBeginBlock

+ func (m *BlockMetadata) GetResponseCommit() *types.ResponseCommit

+ func (m *BlockMetadata) GetResponseEndBlock() *types.ResponseEndBlock

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

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

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

+ func (m *BlockMetadata) Reset()

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

+ func (m *BlockMetadata) String() string

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

+ func (m *BlockMetadata) XXX_DiscardUnknown()

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

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

+ func (m *BlockMetadata) XXX_Size() int

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

+ type BlockMetadata_DeliverTx struct

+ Request *types.RequestDeliverTx

+ Response *types.ResponseDeliverTx

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

+ func (*BlockMetadata_DeliverTx) ProtoMessage()

+ func (m *BlockMetadata_DeliverTx) GetRequest() *types.RequestDeliverTx

+ func (m *BlockMetadata_DeliverTx) GetResponse() *types.ResponseDeliverTx

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

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

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

+ func (m *BlockMetadata_DeliverTx) Reset()

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

+ func (m *BlockMetadata_DeliverTx) String() string

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

+ func (m *BlockMetadata_DeliverTx) XXX_DiscardUnknown()

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

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

+ func (m *BlockMetadata_DeliverTx) XXX_Size() int

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

+ type CapabilityKey StoreKey

+ type Codec interface

+ Marshal func(proto.Message) ([]byte, error)

+ MarshalLengthPrefixed func(proto.Message) ([]byte, error)

+ Unmarshal func(bz []byte, ptr proto.Message) error

+ UnmarshalLengthPrefixed func(bz []byte, ptr proto.Message) error

+ func NewTestCodec() Codec

type CommitID

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

+ func (*CommitID) ProtoMessage()

+ 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) tmcrypto.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 CommitMultiStore

+ AddListeners func(key StoreKey, listeners []WriteListener)

+ ListeningEnabled func(key StoreKey) bool

+ LoadLatestVersionAndUpgrade func(upgrades *StoreUpgrades) error

+ LoadVersionAndUpgrade func(ver int64, upgrades *StoreUpgrades) error

+ RollbackToVersion func(version int64) error

+ SetIAVLCacheSize func(size int)

+ SetIAVLDisableFastNode func(disable bool)

+ SetInitialVersion func(version int64) error

+ SetInterBlockCache func(MultiStorePersistentCache)

+ SetMetrics func(metrics metrics.StoreMetrics)

+ 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 NewSmtCommitmentOp(key []byte, proof *ics23.CommitmentProof) CommitmentOp

+ func (op CommitmentOp) GetKey() []byte

+ func (op CommitmentOp) ProofOp() tmmerkle.ProofOp

+ func (op CommitmentOp) Run(args [][]byte) ([][]byte, error)

type Committer

+ GetPruning func() pruningtypes.PruningOptions

+ type ErrorNegativeGasConsumed struct

+ Descriptor string

type GasMeter

+ GasRemaining func() Gas

+ RefundGas func(amount Gas, descriptor string)

+ String func() string

type Iterator

+ func KVStorePrefixIteratorPaginated(kvs KVStore, prefix []byte, page, limit uint) Iterator

+ func KVStoreReversePrefixIteratorPaginated(kvs KVStore, prefix []byte, page, limit uint) Iterator

+ type MemoryListener struct

+ func NewMemoryListener(key StoreKey) *MemoryListener

+ func (fl *MemoryListener) OnWrite(storeKey StoreKey, key []byte, value []byte, delete bool) error

+ func (fl *MemoryListener) PopStateCache() []StoreKVPair

+ func (fl *MemoryListener) StoreKey() StoreKey

+ type MemoryStoreKey struct

+ func NewMemoryStoreKey(name string) *MemoryStoreKey

+ func (key *MemoryStoreKey) Name() string

+ func (key *MemoryStoreKey) String() string

type MultiStore

+ CacheMultiStoreWithVersion func(version int64) (CacheMultiStore, error)

+ LatestVersion func() int64

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

+ func (wl *StoreKVPairWriteListener) OnWrite(storeKey StoreKey, key []byte, value []byte, delete bool) error

+ type StoreRename struct

+ NewKey string

+ OldKey string

type StoreType

+ const StoreTypeMemory

+ const StoreTypePersistent

+ const StoreTypeSMT

+ func (st StoreType) String() string

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

+ SetInitialVersion func(version int64)

+ type StreamingService interface

+ Listeners func() map[StoreKey][]WriteListener

+ Stream func(wg *sync.WaitGroup) error

+ type TestCodec struct

+ func (pc *TestCodec) Marshal(o proto.Message) ([]byte, error)

+ func (pc *TestCodec) MarshalLengthPrefixed(o proto.Message) ([]byte, error)

+ func (pc *TestCodec) Unmarshal(bz []byte, ptr proto.Message) error

+ func (pc *TestCodec) UnmarshalLengthPrefixed(bz []byte, ptr proto.Message) error

type TraceContext

+ func (tc TraceContext) Clone() TraceContext

+ func (tc TraceContext) Merge(newTc TraceContext) TraceContext

+ type WriteListener interface

+ OnWrite func(storeKey StoreKey, key []byte, value []byte, delete bool) error

v0.33.2

Apr 3, 2019

v0.33.1

Apr 2, 2019

v0.33.0

Mar 7, 2019

v0.32.0

Feb 15, 2019

v0.32.0-rc0

Feb 15, 2019

v0.31.2

Feb 12, 2019

v0.31.1

Feb 9, 2019

v0.31.0

Feb 9, 2019

Changes in this version

+ const GasDeleteDesc

+ const GasHasDesc

+ const GasIterNextCostFlatDesc

+ const GasReadCostFlatDesc

+ const GasReadPerByteDesc

+ const GasValuePerByteDesc

+ const GasWriteCostFlatDesc

+ const GasWritePerByteDesc

+ var PruneEverything = NewPruningOptions(0, 0)

+ var PruneNothing = NewPruningOptions(0, 1)

+ var PruneSyncable = NewPruningOptions(100, 10000)

+ func AssertValidKey(key []byte)

+ func AssertValidValue(value []byte)

+ func Cp(bz []byte) (ret []byte)

+ func DiffKVStores(a KVStore, b KVStore, prefixesToSkip [][]byte) (kvA cmn.KVPair, kvB cmn.KVPair, count int64, equal bool)

+ func InclusiveEndBytes(inclusiveBytes []byte) (exclusiveBytes []byte)

+ func PrefixEndBytes(prefix []byte) []byte

+ type CacheKVStore interface

+ Write func()

+ type CacheMultiStore interface

+ Write func()

+ type CacheWrap interface

+ CacheWrap func() CacheWrap

+ CacheWrapWithTrace func(w io.Writer, tc TraceContext) CacheWrap

+ Write func()

+ type CacheWrapper interface

+ CacheWrap func() CacheWrap

+ CacheWrapWithTrace func(w io.Writer, tc TraceContext) CacheWrap

+ type CommitID struct

+ Hash []byte

+ Version int64

+ func (cid CommitID) IsZero() bool

+ func (cid CommitID) String() string

+ type CommitKVStore interface

+ type CommitMultiStore interface

+ GetCommitKVStore func(key StoreKey) CommitKVStore

+ GetCommitStore func(key StoreKey) CommitStore

+ LoadLatestVersion func() error

+ LoadVersion func(ver int64) error

+ MountStoreWithDB func(key StoreKey, typ StoreType, db dbm.DB)

+ type CommitStore interface

+ type Committer interface

+ Commit func() CommitID

+ LastCommitID func() CommitID

+ SetPruning func(PruningOptions)

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

+ func NewGasMeter(limit Gas) GasMeter

+ func NewInfiniteGasMeter() GasMeter

+ type Iterator = dbm.Iterator

+ func KVStorePrefixIterator(kvs KVStore, prefix []byte) Iterator

+ func KVStoreReversePrefixIterator(kvs KVStore, prefix []byte) Iterator

+ type KVPair cmn.KVPair

+ type KVStore interface

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

+ CacheMultiStore func() CacheMultiStore

+ GetKVStore func(StoreKey) KVStore

+ GetStore func(StoreKey) Store

+ SetTracer func(w io.Writer) MultiStore

+ SetTracingContext func(TraceContext) MultiStore

+ TracingEnabled func() bool

+ type PruningOptions struct

+ func NewPruningOptions(keepRecent, keepEvery int64) PruningOptions

+ func (po PruningOptions) KeepEvery() int64

+ func (po PruningOptions) KeepRecent() int64

+ type Queryable interface

+ Query func(abci.RequestQuery) abci.ResponseQuery

+ type Store interface

+ GetStoreType func() StoreType

+ type StoreKey interface

+ Name func() string

+ String func() string

+ type StoreType int

+ const StoreTypeDB

+ const StoreTypeIAVL

+ const StoreTypeMulti

+ const StoreTypeTransient

+ type TraceContext map[string]interface

+ type TransientStoreKey struct

+ func NewTransientStoreKey(name string) *TransientStoreKey

+ func (key *TransientStoreKey) Name() string

+ func (key *TransientStoreKey) String() string

v0.31.0-rc0

Feb 9, 2019

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