Versions in this module Expand all Collapse all v0 v0.1.0 Jan 19, 2024 Changes in this version + const EthReceipt + const FlagCheckWd + const FlagFastQuery + const FlagFastQueryForWasm + const FlagFastQueryLru + const MsgFunctionDisable + const StdResponse + const TypeDelete + const TypeEvmParams + const TypeOthers + const TypeState + const WatchDBName + const WatchDbDir + var KeyLatestHeight = "LatestHeight" + var PrefixState = []byte + var TransactionFailed = uint32(0) + var TransactionSuccess = uint32(1) + var WatchCdc *codec.Codec + func DecodeAccount(bz []byte) (*app.EthAccount, error) + func EncodeAccount(acc *app.EthAccount) ([]byte, error) + func GetMsgAccountKey(addr []byte) []byte + func GetMsgStateKey(addr common.Address, key []byte) []byte + func GetWatchLruSize() int + func IsRpcNode() bool + func IsWatcherEnabled() bool + func NewBlock(height uint64, blockBloom ethtypes.Bloom, header abci.Header, gasLimit uint64, ...) (types.Block, common.Hash) + func NewEvmTx(msgEvmTx *types.MsgEthereumTx, txHash ethcmn.Hash, blockHash ethcmn.Hash, ...) *evmTx + type Batch struct + Key []byte + TypeValue uint32 + Value []byte + func (b *Batch) MarshalToAmino(cdc *amino.Codec) ([]byte, error) + func (b *Batch) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error + type CodeInfo struct + Code string + Height uint64 + type DelAccMsg struct + func NewDelAccMsg(acc auth.Account) *DelAccMsg + func (delAcc *DelAccMsg) GetKey() []byte + func (delAcc *DelAccMsg) GetType() uint32 + func (delAcc *DelAccMsg) GetValue() string + type LazyValueMarshaler interface + GetValue func() string + type MsgAccount struct + func NewMsgAccount(acc auth.Account) *MsgAccount + func (msgAccount *MsgAccount) GetKey() []byte + func (msgAccount *MsgAccount) GetType() uint32 + func (msgAccount *MsgAccount) GetValue() string + type MsgBlock struct + func NewMsgBlock(b types.Block, blockHash common.Hash) *MsgBlock + func (m MsgBlock) GetKey() []byte + func (m MsgBlock) GetType() uint32 + func (m MsgBlock) GetValue() string + type MsgBlockInfo struct + func NewMsgBlockInfo(height uint64, blockHash common.Hash) *MsgBlockInfo + func (b MsgBlockInfo) GetKey() []byte + func (b MsgBlockInfo) GetType() uint32 + func (b MsgBlockInfo) GetValue() string + type MsgBlockStdTxHash struct + func NewMsgBlockStdTxHash(stdTxHash []common.Hash, blockHash common.Hash) *MsgBlockStdTxHash + func (m *MsgBlockStdTxHash) GetKey() []byte + func (m *MsgBlockStdTxHash) GetType() uint32 + func (m *MsgBlockStdTxHash) GetValue() string + type MsgCode struct + Code string + Key []byte + func NewMsgCode(contractAddr common.Address, code []byte, height uint64) *MsgCode + func (m MsgCode) GetKey() []byte + func (m MsgCode) GetType() uint32 + func (m MsgCode) GetValue() string + type MsgCodeByHash struct + Code string + Key []byte + func NewMsgCodeByHash(hash []byte, code []byte) *MsgCodeByHash + func (m MsgCodeByHash) GetKey() []byte + func (m MsgCodeByHash) GetType() uint32 + func (m MsgCodeByHash) GetValue() string + type MsgContractBlockedListItem struct + func NewMsgContractBlockedListItem(addr sdk.AccAddress) *MsgContractBlockedListItem + func (msgItem *MsgContractBlockedListItem) GetKey() []byte + func (msgItem *MsgContractBlockedListItem) GetType() uint32 + func (msgItem *MsgContractBlockedListItem) GetValue() string + type MsgContractDeploymentWhitelistItem struct + func NewMsgContractDeploymentWhitelistItem(addr sdk.AccAddress) *MsgContractDeploymentWhitelistItem + func (msgItem *MsgContractDeploymentWhitelistItem) GetKey() []byte + func (msgItem *MsgContractDeploymentWhitelistItem) GetType() uint32 + func (msgItem *MsgContractDeploymentWhitelistItem) GetValue() string + type MsgContractMethodBlockedListItem struct + func NewMsgContractMethodBlockedListItem(addr sdk.AccAddress, methods []byte) *MsgContractMethodBlockedListItem + func (msgItem *MsgContractMethodBlockedListItem) GetKey() []byte + func (msgItem *MsgContractMethodBlockedListItem) GetType() uint32 + func (msgItem *MsgContractMethodBlockedListItem) GetValue() string + type MsgDelContractBlockedListItem struct + func NewMsgDelContractBlockedListItem(addr sdk.AccAddress) *MsgDelContractBlockedListItem + func (msgItem *MsgDelContractBlockedListItem) GetKey() []byte + func (msgItem *MsgDelContractBlockedListItem) GetType() uint32 + func (msgItem *MsgDelContractBlockedListItem) GetValue() string + type MsgDelContractDeploymentWhitelistItem struct + func NewMsgDelContractDeploymentWhitelistItem(addr sdk.AccAddress) *MsgDelContractDeploymentWhitelistItem + func (msgItem *MsgDelContractDeploymentWhitelistItem) GetKey() []byte + func (msgItem *MsgDelContractDeploymentWhitelistItem) GetType() uint32 + func (msgItem *MsgDelContractDeploymentWhitelistItem) GetValue() string + type MsgEthTx struct + Key []byte + func (m MsgEthTx) GetKey() []byte + func (m MsgEthTx) GetType() uint32 + type MsgLatestHeight struct + func NewMsgLatestHeight(height uint64) *MsgLatestHeight + func (b MsgLatestHeight) GetKey() []byte + func (b MsgLatestHeight) GetType() uint32 + func (b MsgLatestHeight) GetValue() string + type MsgParams struct + func NewMsgParams(params types.Params) *MsgParams + func (msgParams *MsgParams) GetKey() []byte + func (msgParams *MsgParams) GetType() uint32 + func (msgParams *MsgParams) GetValue() string + type MsgState struct + func NewMsgState(addr common.Address, key, value []byte) *MsgState + func (msgState *MsgState) GetKey() []byte + func (msgState *MsgState) GetType() uint32 + func (msgState *MsgState) GetValue() string + type MsgStdTransactionResponse struct + func NewStdTransactionResponse(tr *ctypes.ResultTx, timestamp time.Time, txHash common.Hash) *MsgStdTransactionResponse + func (tr *MsgStdTransactionResponse) GetKey() []byte + func (tr *MsgStdTransactionResponse) GetType() uint32 + func (tr *MsgStdTransactionResponse) GetValue() string + type MsgTransactionReceipt struct + func NewMsgTransactionReceipt(tr *TransactionReceipt, txHash common.Hash) *MsgTransactionReceipt + func (m MsgTransactionReceipt) GetKey() []byte + func (m MsgTransactionReceipt) GetType() uint32 + type Querier struct + func NewQuerier() *Querier + func (q *Querier) Enable(sw bool) + func (q Querier) DeleteAccountFromRdb(addr sdk.AccAddress) + func (q Querier) DeleteStateFromRdb(addr common.Address, key []byte) + func (q Querier) GetAccount(addr sdk.AccAddress) (*types.EthAccount, error) + func (q Querier) GetAccountFromRdb(addr sdk.AccAddress) (*types.EthAccount, error) + func (q Querier) GetBlockByHash(hash common.Hash, fullTx bool) (*evmtypes.Block, error) + func (q Querier) GetBlockByNumber(number uint64, fullTx bool) (*evmtypes.Block, error) + func (q Querier) GetBlockHashByNumber(number uint64) (common.Hash, error) + func (q Querier) GetCode(contractAddr common.Address, height uint64) ([]byte, error) + func (q Querier) GetCodeByHash(codeHash []byte) ([]byte, error) + func (q Querier) GetContractMethodBlockedList(key []byte) ([]byte, error) + func (q Querier) GetLatestBlockNumber() (uint64, error) + func (q Querier) GetParams() (*evmtypes.Params, error) + func (q Querier) GetState(key []byte) ([]byte, error) + func (q Querier) GetStateFromRdb(key []byte) ([]byte, error) + func (q Querier) GetStdTxHashByBlockHash(hash common.Hash) ([]common.Hash, error) + func (q Querier) GetTransactionByBlockHashAndIndex(hash common.Hash, idx uint) (*Transaction, error) + func (q Querier) GetTransactionByBlockNumberAndIndex(number uint64, idx uint) (*Transaction, error) + func (q Querier) GetTransactionByHash(hash common.Hash) (*Transaction, error) + func (q Querier) GetTransactionReceipt(hash common.Hash) (*TransactionReceipt, error) + func (q Querier) GetTransactionResponse(hash common.Hash) (*TransactionResponse, error) + func (q Querier) GetTransactionsByBlockNumber(number, offset, limit uint64) ([]*Transaction, error) + func (q Querier) GetTxResultByBlock(clientCtx clientcontext.CLIContext, height, offset, limit uint64) ([]*TransactionResult, error) + func (q Querier) HasContractBlockedList(key []byte) bool + func (q Querier) HasContractDeploymentWhitelist(key []byte) bool + func (q Querier) MustGetAccount(addr sdk.AccAddress) (*types.EthAccount, error) + func (q Querier) MustGetState(addr common.Address, key []byte) ([]byte, error) + type Transaction struct + BlockHash *common.Hash + BlockNumber *hexutil.Big + From common.Address + Gas hexutil.Uint64 + GasPrice *hexutil.Big + Hash common.Hash + Input hexutil.Bytes + Nonce hexutil.Uint64 + R *hexutil.Big + S *hexutil.Big + To *common.Address + TransactionIndex *hexutil.Uint64 + V *hexutil.Big + Value *hexutil.Big + func NewTransaction(tx *evmtypes.MsgEthereumTx, txHash, blockHash common.Hash, ...) (*Transaction, error) + func (tr *Transaction) GetValue() string + type TransactionReceipt struct + BlockHash string + BlockNumber hexutil.Uint64 + ContractAddress *common.Address + CumulativeGasUsed hexutil.Uint64 + From string + GasUsed hexutil.Uint64 + Logs []*ethtypes.Log + LogsBloom ethtypes.Bloom + Status hexutil.Uint64 + To *common.Address + TransactionHash string + TransactionIndex hexutil.Uint64 + func NewTransactionReceiptResponse(status uint32, tx *types.MsgEthereumTx, txHash, blockHash common.Hash, ...) *TransactionReceipt + func (tr *TransactionReceipt) GetBlockHash() string + func (tr *TransactionReceipt) GetFrom() string + func (tr *TransactionReceipt) GetHash() string + func (tr *TransactionReceipt) GetTo() *common.Address + func (tr *TransactionReceipt) GetValue() string + type TransactionResponse struct + Timestamp time.Time + type TransactionResult struct + EthTx *Transaction + EthTxLog string + Receipt *TransactionReceipt + Response *WrappedResponseWithCodec + TxType hexutil.Uint64 + func RawTxResultToStdResponse(clientCtx clientcontext.CLIContext, tr *ctypes.ResultTx, tx sdk.Tx, ...) (*TransactionResult, error) + type TxWatcher struct + func NewTxWatcher() *TxWatcher + func (w *TxWatcher) DeleteAccount(account interface{}) + func (w *TxWatcher) DeleteContractBlockedList(addr interface{}) + func (w *TxWatcher) DeleteContractDeploymentWhitelist(addr interface{}) + func (w *TxWatcher) Destruct() []WatchMessage + func (w *TxWatcher) Enabled() bool + func (w *TxWatcher) Finalize() + func (w *TxWatcher) SaveAccount(account interface{}) + func (w *TxWatcher) SaveContractBlockedListItem(addr interface{}) + func (w *TxWatcher) SaveContractCode(addr common.Address, code []byte, height uint64) + func (w *TxWatcher) SaveContractCodeByHash(hash []byte, code []byte) + func (w *TxWatcher) SaveContractDeploymentWhitelistItem(addr interface{}) + func (w *TxWatcher) SaveContractMethodBlockedListItem(addr interface{}, methods []byte) + func (w *TxWatcher) SaveState(addr common.Address, key, value []byte) + type WatchData struct + Batches []*Batch + BloomData []*types.KV + DelayEraseKey [][]byte + DirtyAccount []*sdk.AccAddress + DirtyList [][]byte + func (w *WatchData) MarshalToAmino(cdc *amino.Codec) ([]byte, error) + func (w *WatchData) Size() int + func (w *WatchData) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error + type WatchMessage = sdk.WatchMessage + type WatchStore struct + func InstanceOfWatchStore() *WatchStore + func (w *WatchStore) SetEvmParams(params evmtypes.Params) + func (w WatchStore) Delete(key []byte) + func (w WatchStore) Get(key []byte) ([]byte, error) + func (w WatchStore) GetEvmParams() evmtypes.Params + func (w WatchStore) GetUnsafe(key []byte, processor dbm.UnsafeValueProcessor) (interface{}, error) + func (w WatchStore) Has(key []byte) bool + func (w WatchStore) Iterator(start, end []byte) dbm.Iterator + func (w WatchStore) Set(key []byte, value []byte) + type WatchTx interface + GetFailedReceipts func(cumulativeGas, gasUsed uint64) *TransactionReceipt + GetIndex func() uint64 + GetTransaction func() *Transaction + GetTxHash func() common.Hash + GetTxWatchMessage func() WatchMessage + type Watcher struct + func NewWatcher(logger log.Logger) *Watcher + func (w *Watcher) ApplyWatchData(watchData interface{}) + func (w *Watcher) CheckWatchDB(keys [][]byte, mode string) + func (w *Watcher) Collect(watchers ...sdk.IWatcher) + func (w *Watcher) Commit() + func (w *Watcher) CommitAccountToRpcDb(account auth.Account) + func (w *Watcher) CommitCodeHashToDb(hash []byte, code []byte) + func (w *Watcher) CommitReceiptToDb(txHash common.Hash, receipt *TransactionReceipt) + func (w *Watcher) CommitStateToRpcDb(addr common.Address, key, value []byte) + func (w *Watcher) CommitWatchData(data WatchData) + func (w *Watcher) CreateWatchDataGenerator() func() ([]byte, error) + func (w *Watcher) DelayEraseKey() + func (w *Watcher) DeleteAccount(addr sdk.AccAddress) + func (w *Watcher) Enable(enable bool) + func (w *Watcher) Enabled() bool + func (w *Watcher) ExecuteDelayEraseKey(delayEraseKey [][]byte) + func (w *Watcher) GetBloomDataPoint() *[]*evmtypes.KV + func (w *Watcher) GetEvmTxIndex() uint64 + func (w *Watcher) Height() uint64 + func (w *Watcher) IsFirstUse() bool + func (w *Watcher) IsRealEvmTx(resp *tm.ResponseDeliverTx) bool + func (w *Watcher) NewHeight(height uint64, blockHash common.Hash, header types.Header) + func (w *Watcher) RecordTxAndFailedReceipt(tx tm.TxEssentials, resp *tm.ResponseDeliverTx, txDecoder sdk.TxDecoder) + func (w *Watcher) SaveAccount(account auth.Account) + func (w *Watcher) SaveBlock(block evmtypes.Block) + func (w *Watcher) SaveBlockStdTxHash() + func (w *Watcher) SaveContractBlockedListItem(addr sdk.AccAddress) + func (w *Watcher) SaveContractDeploymentWhitelistItem(addr sdk.AccAddress) + func (w *Watcher) SaveContractMethodBlockedListItem(addr sdk.AccAddress, methods []byte) + func (w *Watcher) SaveLatestHeight(height uint64) + func (w *Watcher) SaveParallelTx(realTx sdk.Tx, resultData *types.ResultData, resp tm.ResponseDeliverTx) + func (w *Watcher) SaveParams(params evmtypes.Params) + func (w *Watcher) SaveTransactionReceipt(status uint32, msg *evmtypes.MsgEthereumTx, txHash common.Hash, txIndex uint64, ...) + func (w *Watcher) SetFirstUse(v bool) + func (w *Watcher) SetWatchDataManager() + func (w *Watcher) Stop() + func (w *Watcher) UnmarshalWatchData(wdByte []byte) (interface{}, error) + func (w *Watcher) UpdateCumulativeGas(txIndex, gasUsed uint64) + func (w *Watcher) Used() + type WrappedResponseWithCodec struct + Codec *codec.Codec + Response sdk.TxResponse + func (wr *WrappedResponseWithCodec) MarshalJSON() ([]byte, error)
Go to main page