watcher

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Jan 5, 2022 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

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

	WatchDbDir  = "data"
	WatchDBName = "watch"
)
View Source 
const (
	TypeOthers = uint32(1)
	TypeState  = uint32(2)
)
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"`
}

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 EthBlock 

type EthBlock 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"`
}

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 (msgAccount *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
	JsonEthTx string
}

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 (m 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 (m 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) (*EthBlock, error)

func (Querier) GetBlockByNumber 

func (q Querier) GetBlockByNumber(number uint64, fullTx bool) (*EthBlock, 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) (*rpctypes.Transaction, error)

func (Querier) GetTransactionByBlockNumberAndIndex 

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

func (Querier) GetTransactionByHash 

func (q Querier) GetTransactionByHash(hash common.Hash) (*rpctypes.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) ([]*rpctypes.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 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) Size added in v1.0.0 

func (w *WatchData) Size() int

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) 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() *Watcher

func (*Watcher) AddDirtyAccount added in v1.0.0 

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

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

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

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) GetWatchData added in v1.1.0 

func (w *Watcher) GetWatchData() ([]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) 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(wdByte []byte)

func (*Watcher) Used added in v0.18.7 

func (w *Watcher) Used()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.