watcher

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: May 6, 2022 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FlagFastQuery    = "fast-query"
	FlagFastQueryLru = "fast-lru"
	FlagDBBackend    = "db_backend"
	FlagCheckWd      = "check_watchdb"

	WatchDbDir  = "data"
	WatchDBName = "watch"
)
View Source
const (
	TypeOthers = uint32(1)
	TypeState  = uint32(2)
	TypeDelete = uint32(3)
)
View Source
const MsgFunctionDisable = "fast query function has been disabled"

Variables

View Source
var (
	PrefixState = []byte{0x08}

	KeyLatestHeight = "LatestHeight"

	TransactionSuccess = uint32(1)
	TransactionFailed  = uint32(0)
)

Functions

func GetMsgAccountKey added in v0.18.7

func GetMsgAccountKey(addr []byte) []byte

func GetMsgStateKey added in v0.18.7

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

func GetWatchLruSize added in v0.18.8

func GetWatchLruSize() int

func IsWatcherEnabled

func IsWatcherEnabled() bool

Types

type Batch added in v1.0.0

type Batch struct {
	Key       []byte `json:"key"`
	Value     []byte `json:"value"`
	TypeValue uint32 `json:"type_value"`
}

func (*Batch) MarshalToAmino added in v1.1.6

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

MarshalToAmino marshal batch data to amino bytes

func (*Batch) UnmarshalFromAmino added in v1.1.6

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

UnmarshalFromAmino unmarshal amino bytes to this object

type Block added in v1.2.0

type Block struct {
	Number           hexutil.Uint64 `json:"number"`
	Hash             common.Hash    `json:"hash"`
	ParentHash       common.Hash    `json:"parentHash"`
	Nonce            BlockNonce     `json:"nonce"`
	UncleHash        common.Hash    `json:"sha3Uncles"`
	LogsBloom        ethtypes.Bloom `json:"logsBloom"`
	TransactionsRoot common.Hash    `json:"transactionsRoot"`
	StateRoot        common.Hash    `json:"stateRoot"`
	Miner            common.Address `json:"miner"`
	MixHash          common.Hash    `json:"mixHash"`
	Difficulty       hexutil.Uint64 `json:"difficulty"`
	TotalDifficulty  hexutil.Uint64 `json:"totalDifficulty"`
	ExtraData        hexutil.Bytes  `json:"extraData"`
	Size             hexutil.Uint64 `json:"size"`
	GasLimit         hexutil.Uint64 `json:"gasLimit"`
	GasUsed          *hexutil.Big   `json:"gasUsed"`
	Timestamp        hexutil.Uint64 `json:"timestamp"`
	Uncles           []common.Hash  `json:"uncles"`
	ReceiptsRoot     common.Hash    `json:"receiptsRoot"`
	Transactions     interface{}    `json:"transactions"`
}

Block represents a transaction returned to RPC clients.

type BlockNonce

type BlockNonce [8]byte

A BlockNonce is a 64-bit hash which proves (combined with the mix-hash) that a sufficient amount of computation has been carried out on a block.

func EncodeNonce

func EncodeNonce(i uint64) BlockNonce

EncodeNonce converts the given integer to a block nonce.

func (BlockNonce) MarshalText

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

MarshalText encodes n as a hex string with 0x prefix.

func (BlockNonce) Uint64

func (n BlockNonce) Uint64() uint64

Uint64 returns the integer value of a block nonce.

func (*BlockNonce) UnmarshalText

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

UnmarshalText implements encoding.TextUnmarshaler.

type CodeInfo

type CodeInfo struct {
	Height uint64 `json:"height"`
	Code   string `json:"code"`
}

type DelAccMsg added in v1.1.5

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

func NewDelAccMsg added in v1.1.5

func NewDelAccMsg(acc auth.Account) *DelAccMsg

func (*DelAccMsg) GetKey added in v1.1.5

func (delAcc *DelAccMsg) GetKey() []byte

func (*DelAccMsg) GetType added in v1.1.5

func (delAcc *DelAccMsg) GetType() uint32

func (*DelAccMsg) GetValue added in v1.1.5

func (delAcc *DelAccMsg) GetValue() string

type LazyValueMarshaler added in v1.1.8

type LazyValueMarshaler interface {
	GetValue() string
}

type MsgAccount added in v0.18.7

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

func NewMsgAccount added in v0.18.7

func NewMsgAccount(acc auth.Account) *MsgAccount

func (*MsgAccount) GetKey added in v0.18.7

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

func (*MsgAccount) GetType added in v0.18.8

func (msgAccount *MsgAccount) GetType() uint32

func (MsgAccount) GetValue added in v0.18.7

func (b MsgAccount) GetValue() string

type MsgBlock

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

func NewMsgBlock

func NewMsgBlock(height uint64, blockBloom ethtypes.Bloom, blockHash common.Hash, header abci.Header, gasLimit uint64, gasUsed *big.Int, txs interface{}) *MsgBlock

func (MsgBlock) GetKey

func (m MsgBlock) GetKey() []byte

func (MsgBlock) GetType added in v0.18.8

func (m MsgBlock) GetType() uint32

func (MsgBlock) GetValue

func (m MsgBlock) GetValue() string

type MsgBlockInfo

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

func NewMsgBlockInfo

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

func (MsgBlockInfo) GetKey

func (b MsgBlockInfo) GetKey() []byte

func (MsgBlockInfo) GetType added in v0.18.8

func (b MsgBlockInfo) GetType() uint32

func (MsgBlockInfo) GetValue

func (b MsgBlockInfo) GetValue() string

type MsgCode

type MsgCode struct {
	Key  []byte
	Code string
}

func NewMsgCode

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

func (MsgCode) GetKey

func (m MsgCode) GetKey() []byte

func (MsgCode) GetType added in v0.18.8

func (m MsgCode) GetType() uint32

func (MsgCode) GetValue

func (m MsgCode) GetValue() string

type MsgCodeByHash added in v0.18.7

type MsgCodeByHash struct {
	Key  []byte
	Code string
}

func NewMsgCodeByHash added in v0.18.7

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

func (MsgCodeByHash) GetKey added in v0.18.7

func (m MsgCodeByHash) GetKey() []byte

func (MsgCodeByHash) GetType added in v0.18.8

func (m MsgCodeByHash) GetType() uint32

func (MsgCodeByHash) GetValue added in v0.18.7

func (m MsgCodeByHash) GetValue() string

type MsgContractBlockedListItem added in v0.18.7

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

func NewMsgContractBlockedListItem added in v0.18.7

func NewMsgContractBlockedListItem(addr sdk.AccAddress) *MsgContractBlockedListItem

func (*MsgContractBlockedListItem) GetKey added in v0.18.7

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

func (*MsgContractBlockedListItem) GetType added in v0.18.8

func (msgItem *MsgContractBlockedListItem) GetType() uint32

func (*MsgContractBlockedListItem) GetValue added in v0.18.7

func (msgItem *MsgContractBlockedListItem) GetValue() string

type MsgContractDeploymentWhitelistItem added in v0.18.7

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

func NewMsgContractDeploymentWhitelistItem added in v0.18.7

func NewMsgContractDeploymentWhitelistItem(addr sdk.AccAddress) *MsgContractDeploymentWhitelistItem

func (*MsgContractDeploymentWhitelistItem) GetKey added in v0.18.7

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

func (*MsgContractDeploymentWhitelistItem) GetType added in v0.18.8

func (msgItem *MsgContractDeploymentWhitelistItem) GetType() uint32

func (*MsgContractDeploymentWhitelistItem) GetValue added in v0.18.7

func (msgItem *MsgContractDeploymentWhitelistItem) GetValue() string

type MsgContractMethodBlockedListItem added in v1.0.0

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

func NewMsgContractMethodBlockedListItem added in v1.0.0

func NewMsgContractMethodBlockedListItem(addr sdk.AccAddress, methods []byte) *MsgContractMethodBlockedListItem

func (*MsgContractMethodBlockedListItem) GetKey added in v1.0.0

func (msgItem *MsgContractMethodBlockedListItem) GetKey() []byte

func (*MsgContractMethodBlockedListItem) GetType added in v1.0.0

func (msgItem *MsgContractMethodBlockedListItem) GetType() uint32

func (*MsgContractMethodBlockedListItem) GetValue added in v1.0.0

func (msgItem *MsgContractMethodBlockedListItem) GetValue() string

type MsgEthTx

type MsgEthTx struct {
	Key []byte
	// contains filtered or unexported fields
}

func NewMsgEthTx

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

func (MsgEthTx) GetKey

func (m MsgEthTx) GetKey() []byte

func (MsgEthTx) GetType added in v0.18.8

func (m MsgEthTx) GetType() uint32

func (MsgEthTx) GetValue

func (b MsgEthTx) GetValue() string

type MsgLatestHeight

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

func NewMsgLatestHeight

func NewMsgLatestHeight(height uint64) *MsgLatestHeight

func (MsgLatestHeight) GetKey

func (b MsgLatestHeight) GetKey() []byte

func (MsgLatestHeight) GetType added in v0.18.8

func (b MsgLatestHeight) GetType() uint32

func (MsgLatestHeight) GetValue

func (b MsgLatestHeight) GetValue() string

type MsgParams added in v0.18.7

type MsgParams struct {
	types.Params
}

func NewMsgParams added in v0.18.7

func NewMsgParams(params types.Params) *MsgParams

func (*MsgParams) GetKey added in v0.18.7

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

func (*MsgParams) GetType added in v0.18.8

func (msgParams *MsgParams) GetType() uint32

func (*MsgParams) GetValue added in v0.18.7

func (msgParams *MsgParams) GetValue() string

type MsgState added in v0.18.7

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

func NewMsgState added in v0.18.7

func NewMsgState(addr common.Address, key, value []byte) *MsgState

func (*MsgState) GetKey added in v0.18.7

func (msgState *MsgState) GetKey() []byte

func (*MsgState) GetType added in v0.18.8

func (msgState *MsgState) GetType() uint32

func (*MsgState) GetValue added in v0.18.7

func (msgState *MsgState) GetValue() string

type MsgTransactionReceipt

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

func NewMsgTransactionReceipt

func NewMsgTransactionReceipt(status uint32, tx *types.MsgEthereumTx, txHash, blockHash common.Hash, txIndex, height uint64, data *types.ResultData, cumulativeGas, GasUsed uint64) *MsgTransactionReceipt

func (MsgTransactionReceipt) GetKey

func (m MsgTransactionReceipt) GetKey() []byte

func (MsgTransactionReceipt) GetType added in v0.18.8

func (m MsgTransactionReceipt) GetType() uint32

func (MsgTransactionReceipt) GetValue

func (b MsgTransactionReceipt) GetValue() string

type Querier

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

func NewQuerier

func NewQuerier() *Querier

func (Querier) DeleteAccountFromRdb added in v0.18.8

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

func (Querier) DeleteStateFromRdb added in v0.18.8

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

func (*Querier) Enable

func (q *Querier) Enable(sw bool)

func (Querier) GetAccount added in v0.18.7

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

func (Querier) GetAccountFromRdb added in v0.18.7

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

func (Querier) GetBlockByHash

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

func (Querier) GetBlockByNumber

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

func (Querier) GetBlockHashByNumber added in v0.18.8

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

func (Querier) GetCode

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

func (Querier) GetCodeByHash added in v0.18.7

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

func (Querier) GetContractMethodBlockedList added in v1.0.0

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

func (Querier) GetLatestBlockNumber

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

func (Querier) GetParams added in v0.18.7

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

func (Querier) GetState added in v0.18.7

func (q Querier) GetState(key []byte) ([]byte, error)

func (Querier) GetStateFromRdb added in v0.18.7

func (q Querier) GetStateFromRdb(key []byte) ([]byte, error)

func (Querier) GetTransactionByBlockHashAndIndex

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

func (Querier) GetTransactionByBlockNumberAndIndex

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

func (Querier) GetTransactionByHash

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

func (Querier) GetTransactionReceipt

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

func (Querier) GetTransactionsByBlockNumber added in v0.19.14

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

func (Querier) HasContractBlockedList added in v0.18.7

func (q Querier) HasContractBlockedList(key []byte) bool

func (Querier) HasContractDeploymentWhitelist added in v0.18.7

func (q Querier) HasContractDeploymentWhitelist(key []byte) bool

func (Querier) MustGetAccount added in v0.18.7

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

func (Querier) MustGetState added in v0.18.7

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

type Transaction added in v1.2.0

type Transaction struct {
	BlockHash        *common.Hash    `json:"blockHash"`
	BlockNumber      *hexutil.Big    `json:"blockNumber"`
	From             common.Address  `json:"from"`
	Gas              hexutil.Uint64  `json:"gas"`
	GasPrice         *hexutil.Big    `json:"gasPrice"`
	Hash             common.Hash     `json:"hash"`
	Input            hexutil.Bytes   `json:"input"`
	Nonce            hexutil.Uint64  `json:"nonce"`
	To               *common.Address `json:"to"`
	TransactionIndex *hexutil.Uint64 `json:"transactionIndex"`
	Value            *hexutil.Big    `json:"value"`
	V                *hexutil.Big    `json:"v"`
	R                *hexutil.Big    `json:"r"`
	S                *hexutil.Big    `json:"s"`
}

Transaction represents a transaction returned to RPC clients.

func NewTransaction added in v1.2.0

func NewTransaction(tx *evmtypes.MsgEthereumTx, txHash, blockHash common.Hash, blockNumber, index uint64) (*Transaction, error)

NewTransaction returns a transaction that will serialize to the RPC representation, with the given location metadata set (if available).

type TransactionReceipt

type TransactionReceipt struct {
	Status            hexutil.Uint64  `json:"status"`
	CumulativeGasUsed hexutil.Uint64  `json:"cumulativeGasUsed"`
	LogsBloom         ethtypes.Bloom  `json:"logsBloom"`
	Logs              []*ethtypes.Log `json:"logs"`
	TransactionHash   string          `json:"transactionHash"`
	ContractAddress   *common.Address `json:"contractAddress"`
	GasUsed           hexutil.Uint64  `json:"gasUsed"`
	BlockHash         string          `json:"blockHash"`
	BlockNumber       hexutil.Uint64  `json:"blockNumber"`
	TransactionIndex  hexutil.Uint64  `json:"transactionIndex"`
	From              string          `json:"from"`
	To                *common.Address `json:"to"`
}

type WatchData added in v1.0.0

type WatchData struct {
	DirtyAccount  []*sdk.AccAddress `json:"dirty_account"`
	Batches       []*Batch          `json:"batches"`
	DelayEraseKey [][]byte          `json:"delay_erase_key"`
	BloomData     []*types.KV       `json:"bloom_data"`
	DirtyList     [][]byte          `json:"dirty_list"`
}

func (*WatchData) MarshalToAmino added in v1.1.6

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

MarshalToAmino marshal to amino bytes

func (*WatchData) Size added in v1.0.0

func (w *WatchData) Size() int

func (*WatchData) UnmarshalFromAmino added in v1.1.6

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

UnmarshalFromAmino unmarshal from amino bytes

type WatchMessage

type WatchMessage interface {
	GetKey() []byte
	GetValue() string
	GetType() uint32
}

type WatchStore

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

func InstanceOfWatchStore

func InstanceOfWatchStore() *WatchStore

func (WatchStore) Delete added in v0.18.7

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

func (WatchStore) Get

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

func (WatchStore) GetUnsafe added in v1.2.0

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

func (WatchStore) Has added in v0.18.7

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

func (WatchStore) Iterator added in v1.1.0

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

func (WatchStore) Set

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

type Watcher

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

func NewWatcher

func NewWatcher(logger log.Logger) *Watcher

func (*Watcher) AddDelAccMsg added in v1.1.5

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

func (*Watcher) CheckWatchDB added in v1.1.1

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

func (*Watcher) Commit

func (w *Watcher) Commit()

func (*Watcher) CommitAccountToRpcDb added in v0.18.7

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

func (*Watcher) CommitCodeHashToDb added in v0.18.7

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

func (*Watcher) CommitStateToRpcDb added in v0.18.7

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

func (*Watcher) CommitWatchData added in v1.0.0

func (w *Watcher) CommitWatchData(data WatchData, delayEraseKey [][]byte)

func (*Watcher) DeleteAccount added in v0.18.7

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

func (*Watcher) DeleteContractBlockedList added in v0.18.7

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

func (*Watcher) DeleteContractDeploymentWhitelist added in v0.18.7

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

func (*Watcher) Enable

func (w *Watcher) Enable(sw bool)

func (*Watcher) Enabled added in v0.18.7

func (w *Watcher) Enabled() bool

func (*Watcher) ExecuteDelayEraseKey added in v0.18.9

func (w *Watcher) ExecuteDelayEraseKey(delayEraseKey [][]byte)

func (*Watcher) Finalize added in v0.18.7

func (w *Watcher) Finalize()

func (*Watcher) GetBloomDataPoint added in v1.0.0

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

func (*Watcher) GetWatchDataFunc added in v1.1.6

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

func (*Watcher) IsFirstUse added in v0.18.7

func (w *Watcher) IsFirstUse() bool

func (*Watcher) NewHeight

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

func (*Watcher) Reset added in v0.18.7

func (w *Watcher) Reset()

func (*Watcher) SaveAccount added in v0.18.7

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

func (*Watcher) SaveBlock

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

func (*Watcher) SaveContractBlockedListItem added in v0.18.7

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

func (*Watcher) SaveContractCode

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

func (*Watcher) SaveContractCodeByHash added in v0.18.7

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

func (*Watcher) SaveContractDeploymentWhitelistItem added in v0.18.7

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

func (*Watcher) SaveContractMethodBlockedListItem added in v1.0.0

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

func (*Watcher) SaveEthereumTx

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

func (*Watcher) SaveLatestHeight

func (w *Watcher) SaveLatestHeight(height uint64)

func (*Watcher) SaveParams added in v0.18.7

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

func (*Watcher) SaveState added in v0.18.7

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

func (*Watcher) SaveTransactionReceipt

func (w *Watcher) SaveTransactionReceipt(status uint32, msg *evmtypes.MsgEthereumTx, txHash common.Hash, txIndex uint64, data *evmtypes.ResultData, gasUsed uint64)

func (*Watcher) SetWatchDataFunc added in v1.0.0

func (w *Watcher) SetWatchDataFunc()

func (*Watcher) UnmarshalWatchData added in v1.1.6

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

func (*Watcher) UpdateBlockTxs

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

func (*Watcher) UpdateCumulativeGas

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

func (*Watcher) UseWatchData added in v1.1.0

func (w *Watcher) UseWatchData(watchData interface{})

func (*Watcher) Used added in v0.18.7

func (w *Watcher) Used()

Jump to

Keyboard shortcuts

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