watcher

May 16, 2023

Changes in this version

+ const FlagFastQueryForWasm

Apr 12, 2023

Changes in this version

type TransactionResult

+ EthTxLog string

Dec 1, 2022

Changes in this version

type Watcher

+ func (w *Watcher) IsRealEvmTx(resp *tm.ResponseDeliverTx) bool

Sep 7, 2022

Changes in this version

type Watcher

+ func (w *Watcher) Stop()

Aug 25, 2022

Changes in this version

+ const EthReceipt

+ const StdResponse

+ var WatchCdc *codec.Codec

+ func DecodeAccount(bz []byte) (*app.EthAccount, error)

+ func EncodeAccount(acc *app.EthAccount) ([]byte, error)

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

+ func (q Querier) GetStdTxHashByBlockHash(hash common.Hash) ([]common.Hash, error)

+ func (q Querier) GetTransactionResponse(hash common.Hash) (*TransactionResponse, error)

+ func (q Querier) GetTxResultByBlock(clientCtx clientcontext.CLIContext, height, offset, limit uint64) ([]*TransactionResult, error)

+ type TransactionResponse struct

+ Timestamp time.Time

+ type TransactionResult struct

+ EthTx *Transaction

+ Receipt *TransactionReceipt

+ Response *WrappedResponseWithCodec

+ TxType hexutil.Uint64

+ func RawTxResultToStdResponse(clientCtx clientcontext.CLIContext, tr *ctypes.ResultTx, timestamp time.Time) (*TransactionResult, error)

type Watcher

+ func (w *Watcher) ApplyWatchData(watchData interface{})

+ func (w *Watcher) CreateWatchDataGenerator() func() ([]byte, error)

+ func (w *Watcher) SaveBlockStdTxHash()

+ func (w *Watcher) SetWatchDataManager()

+ type WrappedResponseWithCodec struct

+ Codec *codec.Codec

+ Response sdk.TxResponse

+ func (wr *WrappedResponseWithCodec) MarshalJSON() ([]byte, error)

Jul 29, 2022

Changes in this version

type TransactionReceipt

+ func (tr *TransactionReceipt) GetBlockHash() string

+ func (tr *TransactionReceipt) GetFrom() string

+ func (tr *TransactionReceipt) GetHash() string

+ func (tr *TransactionReceipt) GetTo() *common.Address

Jul 18, 2022

Changes in this version

+ const TypeEvmParams

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

+ func (w *WatchStore) SetEvmParams(params evmtypes.Params)

+ func (w WatchStore) GetEvmParams() evmtypes.Params

type Watcher

+ func (w *Watcher) Collect(watchers ...sdk.IWatcher)

+ func (w *Watcher) SaveParallelTx(msgs []sdk.Msg, resultData *types.ResultData, resp tm.ResponseDeliverTx)

Jun 17, 2022

Changes in this version

+ type InfuraKeeper interface

+ OnSaveBlock func(Block)

+ OnSaveContractCode func(address string, code []byte)

+ OnSaveTransaction func(Transaction)

+ OnSaveTransactionReceipt func(TransactionReceipt)

type WatchTx

+ GetTransaction func() *Transaction

type Watcher

+ InfuraKeeper InfuraKeeper

+ func (w *Watcher) Height() uint64

+ func (w *Watcher) SetFirstUse(v bool)

Jun 14, 2022

Changes in this version

type Transaction

+ func (tr *Transaction) GetValue() string

type TransactionReceipt

+ func (tr *TransactionReceipt) GetValue() string

May 23, 2022

Changes in this version

type Watcher

+ func (w *Watcher) DelayEraseKey()

Apr 28, 2022

Changes in this version

+ func NewEvmTx(msgEvmTx *types.MsgEthereumTx, txHash ethcmn.Hash, blockHash ethcmn.Hash, ...) *evmTx

type MsgTransactionReceipt

+ func NewEvmTransactionReceipt(status uint32, tx *types.MsgEthereumTx, txHash, blockHash common.Hash, ...) *MsgTransactionReceipt

+ type WatchTx interface

+ GetFailedReceipts func(cumulativeGas, gasUsed uint64) WatchMessage

+ GetIndex func() uint64

+ GetTxHash func() common.Hash

+ GetTxWatchMessage func() WatchMessage

type Watcher

+ func (w *Watcher) GetEvmTxIndex() uint64

+ func (w *Watcher) RecordTxAndFailedReceipt(tx tm.TxEssentials, resp *tm.ResponseDeliverTx, txDecoder sdk.TxDecoder)

Mar 23, 2022

Changes in this version

+ type Block struct

+ Difficulty hexutil.Uint64

+ ExtraData hexutil.Bytes

+ GasLimit hexutil.Uint64

+ GasUsed *hexutil.Big

+ Hash common.Hash

+ LogsBloom ethtypes.Bloom

+ Miner common.Address

+ MixHash common.Hash

+ Nonce BlockNonce

+ Number hexutil.Uint64

+ ParentHash common.Hash

+ ReceiptsRoot common.Hash

+ Size hexutil.Uint64

+ StateRoot common.Hash

+ Timestamp hexutil.Uint64

+ TotalDifficulty hexutil.Uint64

+ Transactions interface{}

+ TransactionsRoot common.Hash

+ UncleHash common.Hash

+ Uncles []common.Hash

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

type WatchStore

+ func (w WatchStore) GetUnsafe(key []byte, processor dbm.UnsafeValueProcessor) (interface{}, error)

Feb 18, 2022

Changes in this version

+ type LazyValueMarshaler interface

+ GetValue func() string

Jan 30, 2022

Changes in this version

type Batch

+ func (b *Batch) MarshalToAmino(cdc *amino.Codec) ([]byte, error)

+ func (b *Batch) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error

type WatchData

+ func (w *WatchData) MarshalToAmino(cdc *amino.Codec) ([]byte, error)

+ func (w *WatchData) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error

type Watcher

+ func (w *Watcher) GetWatchDataFunc() func() ([]byte, error)

+ func (w *Watcher) UnmarshalWatchData(wdByte []byte) (interface{}, error)

Jan 19, 2022

Changes in this version

+ const TypeDelete

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

+ func (w *Watcher) AddDelAccMsg(account auth.Account, isDirectly bool)

Jan 10, 2022

Changes in this version

+ const FlagCheckWd

type Watcher

+ func (w *Watcher) CheckWatchDB(keys [][]byte, mode string)

Jan 5, 2022

Changes in this version

type WatchStore

+ func (w WatchStore) Iterator(start, end []byte) dbm.Iterator

type Watcher

+ func (w *Watcher) GetWatchData() ([]byte, error)

+ func (w *Watcher) UseWatchData(wdByte []byte)

Dec 22, 2021

Changes in this version

+ func IsCenterEnabled() bool

+ type Batch struct

+ Key []byte

+ TypeValue uint32

+ Value []byte

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

+ func (q Querier) GetContractMethodBlockedList(key []byte) ([]byte, error)

+ type WatchData struct

+ Batches []*Batch

+ BloomData []*types.KV

+ DelayEraseKey [][]byte

+ DirtyAccount []*sdk.AccAddress

+ DirtyList [][]byte

+ func (w *WatchData) Size() int

type Watcher

+ func (w *Watcher) AddDirtyAccount(addr *sdk.AccAddress)

+ func (w *Watcher) CommitWatchData()

+ func (w *Watcher) GetBloomDataPoint() *[]*evmtypes.KV

+ func (w *Watcher) SaveContractMethodBlockedListItem(addr sdk.AccAddress, methods []byte)

+ func (w *Watcher) SetWatchDataFunc()

Nov 13, 2021

Changes in this version

type Querier

+ func (q Querier) GetTransactionsByBlockNumber(number, offset, limit uint64) ([]*rpctypes.Transaction, error)

Oct 18, 2021

Changes in this version

+ const FlagDBBackend

+ const WatchDBName

Jul 12, 2021

Changes in this version

+ const WatchDbDir

Jun 17, 2021

Changes in this version

type Watcher

+ func (w *Watcher) ExecuteDelayEraseKey()

Jun 15, 2021

Changes in this version

+ const FlagFastQueryLru

+ const TypeOthers

+ const TypeState

+ func GetWatchLruSize() int

type EthBlock

+ UncleHash common.Hash

type MsgAccount

+ func (msgAccount *MsgAccount) GetType() uint32

type MsgBlock

+ func (m MsgBlock) GetType() uint32

type MsgBlockInfo

+ func (b MsgBlockInfo) GetType() uint32

type MsgCode

+ func (m MsgCode) GetType() uint32

type MsgCodeByHash

+ func (m MsgCodeByHash) GetType() uint32

type MsgContractBlockedListItem

+ func (msgItem *MsgContractBlockedListItem) GetType() uint32

type MsgContractDeploymentWhitelistItem

+ func (msgItem *MsgContractDeploymentWhitelistItem) GetType() uint32

type MsgEthTx

+ func (m MsgEthTx) GetType() uint32

type MsgLatestHeight

+ func (b MsgLatestHeight) GetType() uint32

type MsgParams

+ func (msgParams *MsgParams) GetType() uint32

type MsgState

+ func (msgState *MsgState) GetType() uint32

type MsgTransactionReceipt

+ func (m MsgTransactionReceipt) GetType() uint32

type Querier

+ func (q Querier) DeleteAccountFromRdb(addr sdk.AccAddress)

+ func (q Querier) DeleteStateFromRdb(addr common.Address, key []byte)

+ func (q Querier) GetBlockHashByNumber(number uint64) (common.Hash, error)

type WatchMessage

+ GetType func() uint32

May 20, 2021

Changes in this version

+ var PrefixState = []byte

+ func GetMsgAccountKey(addr []byte) []byte

+ func GetMsgStateKey(addr common.Address, key []byte) []byte

+ type MsgAccount struct

+ func NewMsgAccount(acc auth.Account) *MsgAccount

+ func (msgAccount *MsgAccount) GetKey() []byte

+ func (msgAccount *MsgAccount) GetValue() string

+ type MsgCodeByHash struct

+ Code string

+ Key []byte

+ func NewMsgCodeByHash(hash []byte, code []byte, height uint64) *MsgCodeByHash

+ func (m MsgCodeByHash) GetKey() []byte

+ func (m MsgCodeByHash) GetValue() string

+ type MsgContractBlockedListItem struct

+ func NewMsgContractBlockedListItem(addr sdk.AccAddress) *MsgContractBlockedListItem

+ func (msgItem *MsgContractBlockedListItem) GetKey() []byte

+ func (msgItem *MsgContractBlockedListItem) GetValue() string

+ type MsgContractDeploymentWhitelistItem struct

+ func NewMsgContractDeploymentWhitelistItem(addr sdk.AccAddress) *MsgContractDeploymentWhitelistItem

+ func (msgItem *MsgContractDeploymentWhitelistItem) GetKey() []byte

+ func (msgItem *MsgContractDeploymentWhitelistItem) GetValue() string

+ type MsgParams struct

+ func NewMsgParams(params types.Params) *MsgParams

+ func (msgParams *MsgParams) GetKey() []byte

+ 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) GetValue() string

type Querier

+ func (q Querier) GetAccount(addr sdk.AccAddress) (*types.EthAccount, error)

+ func (q Querier) GetAccountFromRdb(addr sdk.AccAddress) (*types.EthAccount, error)

+ func (q Querier) GetCodeByHash(codeHash []byte) ([]byte, error)

+ func (q Querier) GetParams() (*evmtypes.Params, error)

+ func (q Querier) GetState(addr common.Address, key []byte) ([]byte, error)

+ func (q Querier) GetStateFromRdb(addr common.Address, key []byte) ([]byte, 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 WatchStore

+ func (w WatchStore) Delete(key []byte)

+ func (w WatchStore) Has(key []byte) bool

type Watcher

+ func (w *Watcher) CommitAccountToRpcDb(account auth.Account)

+ func (w *Watcher) CommitCodeHashToDb(hash []byte, code []byte)

+ func (w *Watcher) CommitStateToRpcDb(addr common.Address, key, value []byte)

+ func (w *Watcher) DeleteAccount(addr sdk.AccAddress)

+ func (w *Watcher) DeleteContractBlockedList(addr sdk.AccAddress)

+ func (w *Watcher) DeleteContractDeploymentWhitelist(addr sdk.AccAddress)

+ func (w *Watcher) Enabled() bool

+ func (w *Watcher) Finalize()

+ func (w *Watcher) IsFirstUse() bool

+ func (w *Watcher) Reset()

+ func (w *Watcher) SaveAccount(account auth.Account)

+ func (w *Watcher) SaveContractBlockedListItem(addr sdk.AccAddress)

+ func (w *Watcher) SaveContractCodeByHash(hash []byte, code []byte)

+ func (w *Watcher) SaveContractDeploymentWhitelistItem(addr sdk.AccAddress)

+ func (w *Watcher) SaveParams(params evmtypes.Params)

+ func (w *Watcher) SaveState(addr common.Address, key, value []byte)

+ func (w *Watcher) Used()

Apr 12, 2021

Changes in this version

+ const FlagFastQuery

+ const KeyLatestHeight

+ const MsgFunctionDisable

+ const TransactionFailed

+ const TransactionSuccess

+ func IsWatcherEnabled() bool

+ type BlockNonce [8]byte

+ func EncodeNonce(i uint64) BlockNonce

+ func (n *BlockNonce) UnmarshalText(input []byte) error

+ func (n BlockNonce) MarshalText() ([]byte, error)

+ func (n BlockNonce) Uint64() uint64

+ type CodeInfo struct

+ Code string

+ Height uint64

+ type EthBlock struct

+ Difficulty hexutil.Uint64

+ ExtraData hexutil.Bytes

+ GasLimit hexutil.Uint64

+ GasUsed *hexutil.Big

+ Hash common.Hash

+ LogsBloom ethtypes.Bloom

+ Miner common.Address

+ MixHash common.Hash

+ Nonce BlockNonce

+ Number hexutil.Uint64

+ ParentHash common.Hash

+ ReceiptsRoot common.Hash

+ Sha3Uncles common.Hash

+ Size hexutil.Uint64

+ StateRoot common.Hash

+ Timestamp hexutil.Uint64

+ TotalDifficulty hexutil.Uint64

+ Transactions interface{}

+ TransactionsRoot common.Hash

+ Uncles []string

+ type MsgBlock struct

+ func NewMsgBlock(height uint64, blockBloom ethtypes.Bloom, blockHash common.Hash, ...) *MsgBlock

+ func (m MsgBlock) GetKey() string

+ func (m MsgBlock) GetValue() string

+ type MsgBlockInfo struct

+ func NewMsgBlockInfo(height uint64, blockHash common.Hash) *MsgBlockInfo

+ func (b MsgBlockInfo) GetKey() string

+ func (b MsgBlockInfo) GetValue() string

+ type MsgCode struct

+ Code string

+ Key string

+ func NewMsgCode(contractAddr common.Address, code []byte, height uint64) *MsgCode

+ func (m MsgCode) GetKey() string

+ func (m MsgCode) GetValue() string

+ type MsgEthTx struct

+ JsonEthTx string

+ Key string

+ func NewMsgEthTx(tx *types.MsgEthereumTx, txHash, blockHash common.Hash, height, index uint64) *MsgEthTx

+ func (m MsgEthTx) GetKey() string

+ func (m MsgEthTx) GetValue() string

+ type MsgLatestHeight struct

+ func NewMsgLatestHeight(height uint64) *MsgLatestHeight

+ func (b MsgLatestHeight) GetKey() string

+ func (b MsgLatestHeight) GetValue() string

+ type MsgTransactionReceipt struct

+ func NewMsgTransactionReceipt(status uint32, tx *types.MsgEthereumTx, txHash, blockHash common.Hash, ...) *MsgTransactionReceipt

+ func (m MsgTransactionReceipt) GetKey() string

+ func (m MsgTransactionReceipt) GetValue() string

+ type Querier struct

+ func NewQuerier() *Querier

+ func (q *Querier) Enable(sw bool)

+ func (q Querier) GetBlockByHash(hash common.Hash, fullTx bool) (*EthBlock, error)

+ func (q Querier) GetBlockByNumber(number uint64, fullTx bool) (*EthBlock, error)

+ func (q Querier) GetCode(contractAddr common.Address, height uint64) ([]byte, error)

+ func (q Querier) GetLatestBlockNumber() (uint64, error)

+ func (q Querier) GetTransactionByBlockHashAndIndex(hash common.Hash, idx uint) (*rpctypes.Transaction, error)

+ func (q Querier) GetTransactionByBlockNumberAndIndex(number uint64, idx uint) (*rpctypes.Transaction, error)

+ func (q Querier) GetTransactionByHash(hash common.Hash) (*rpctypes.Transaction, error)

+ func (q Querier) GetTransactionReceipt(hash common.Hash) (*TransactionReceipt, error)

+ 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

+ type WatchMessage interface

+ GetKey func() string

+ GetValue func() string

+ type WatchStore struct

+ func InstanceOfWatchStore() *WatchStore

+ func (w WatchStore) Get(key []byte) ([]byte, error)

+ func (w WatchStore) Set(key []byte, value []byte)

+ type Watcher struct

+ func NewWatcher() *Watcher

+ func (w *Watcher) Commit()

+ func (w *Watcher) Enable(sw bool)

+ func (w *Watcher) NewHeight(height uint64, blockHash common.Hash, header types.Header)

+ func (w *Watcher) SaveBlock(bloom ethtypes.Bloom)

+ func (w *Watcher) SaveContractCode(addr common.Address, code []byte)

+ func (w *Watcher) SaveEthereumTx(msg types2.MsgEthereumTx, txHash common.Hash, index uint64)

+ func (w *Watcher) SaveLatestHeight(height uint64)

+ func (w *Watcher) SaveTransactionReceipt(status uint32, msg types2.MsgEthereumTx, txHash common.Hash, txIndex uint64, ...)

+ func (w *Watcher) UpdateBlockTxs(txHash common.Hash)

+ func (w *Watcher) UpdateCumulativeGas(txIndex, gasUsed uint64)