Documentation ¶
Index ¶
- Constants
- func BaseFeeFromEvents(events []abci.Event) *big.Int
- func BlockMaxGasFromConsensusParams(ctx context.Context, clientCtx client.Context, blockHeight int64) (int64, error)
- func CheckTxFee(gasPrice *big.Int, gas uint64, cap float64) error
- func ContextWithHeight(height int64) context.Context
- func EthHeaderFromTendermint(header tmtypes.Header, bloom ethtypes.Bloom, baseFee *big.Int) *ethtypes.Header
- func FormatBlock(header tmtypes.Header, size int, gasLimit int64, gasUsed *big.Int, ...) map[string]interface{}
- func ParseTxIndexerResult(txResult *tmrpctypes.ResultTx, tx sdk.Tx, getter func(*ParsedTxs) *ParsedTx) (*types.TxResult, error)
- func RawTxToEthTx(clientCtx client.Context, txBz tmtypes.Tx) ([]*evmtypes.MsgEthereumTx, error)
- func TxExceedBlockGasLimit(res *abci.ResponseDeliverTx) bool
- func TxSuccessOrExceedsBlockGasLimit(res *abci.ResponseDeliverTx) bool
- type AccountResult
- type AddrLocker
- type Block
- func (b *Block) Body() *ethtypes.Body
- func (b *Block) EthBlock() *ethtypes.Block
- func (b *Block) Hash() common.Hash
- func (b *Block) Header() *ethtypes.Header
- func (b *Block) Number() *big.Int
- func (b *Block) SetHash(hash common.Hash)
- func (b *Block) Size() uint64
- func (b *Block) Transaction(hash common.Hash) *ethtypes.Transaction
- func (b *Block) Transactions() ethtypes.Transactions
- func (b *Block) Uncles() []*ethtypes.Header
- func (b *Block) Withdrawals() ethtypes.Withdrawals
- type BlockNumber
- type BlockNumberOrHash
- type EventFormat
- type FeeHistoryResult
- type NetworkingStack
- type OneFeeHistory
- type OverrideAccount
- type ParsedTx
- type ParsedTxs
- type QueryClient
- type RPCTransaction
- type SignTransactionResult
- type StateOverride
- type StorageResult
Constants ¶
const ( EthPendingBlockNumber = BlockNumber(-2) EthLatestBlockNumber = BlockNumber(-1) EthEarliestBlockNumber = BlockNumber(0) )
const ( BlockParamEarliest = "earliest" BlockParamLatest = "latest" BlockParamFinalized = "finalized" BlockParamSafe = "safe" BlockParamPending = "pending" )
const ExceedBlockGasLimitError = "out of gas in location: block gas meter; gasWanted:"
ExceedBlockGasLimitError defines the error message when txs execution exceeds the block gas limit. The txs fee is deducted in ante handler, so it shouldn't be ignored in JSON-RPC API.
Variables ¶
This section is empty.
Functions ¶
func BaseFeeFromEvents ¶
BaseFeeFromEvents parses the fee basefee from cosmos events
func BlockMaxGasFromConsensusParams ¶
func BlockMaxGasFromConsensusParams(ctx context.Context, clientCtx client.Context, blockHeight int64) (int64, error)
BlockMaxGasFromConsensusParams returns the gas limit for the current block from the chain consensus params.
func CheckTxFee ¶
CheckTxFee is an internal function used to check whether the fee of the given txs is _reasonable_(under the cap).
func ContextWithHeight ¶
ContextWithHeight wraps a context with the a gRPC block height header. If the provided height is 0, it will return an empty context and the gRPC query will use the latest block height for querying. Note that all metadata are processed and removed by tendermint layer, so it wont be accessible at gRPC server level.
func EthHeaderFromTendermint ¶
func EthHeaderFromTendermint(header tmtypes.Header, bloom ethtypes.Bloom, baseFee *big.Int) *ethtypes.Header
EthHeaderFromTendermint is an util function that returns an Ethereum Header from a tendermint Header.
func FormatBlock ¶
func FormatBlock( header tmtypes.Header, size int, gasLimit int64, gasUsed *big.Int, transactions []interface{}, bloom ethtypes.Bloom, validatorAddr common.Address, baseFee *big.Int, ) map[string]interface{}
FormatBlock creates an ethereum block from a tendermint header and ethereum-formatted transactions.
func ParseTxIndexerResult ¶
func ParseTxIndexerResult(txResult *tmrpctypes.ResultTx, tx sdk.Tx, getter func(*ParsedTxs) *ParsedTx) (*types.TxResult, error)
ParseTxIndexerResult parse tm txs result to a format compatible with the custom txs indexer.
func RawTxToEthTx ¶
RawTxToEthTx returns a evm MsgEthereum txs from raw txs bytes.
func TxExceedBlockGasLimit ¶
func TxExceedBlockGasLimit(res *abci.ResponseDeliverTx) bool
TxExceedBlockGasLimit returns true if the txs exceeds block gas limit.
func TxSuccessOrExceedsBlockGasLimit ¶
func TxSuccessOrExceedsBlockGasLimit(res *abci.ResponseDeliverTx) bool
TxSuccessOrExceedsBlockGasLimit returnsrue if the txs was successful or if it failed with an ExceedBlockGasLimit error
Types ¶
type AccountResult ¶
type AccountResult struct { Address common.Address `json:"address"` AccountProof []string `json:"accountProof"` Balance *hexutil.Big `json:"balance"` CodeHash common.Hash `json:"codeHash"` Nonce hexutil.Uint64 `json:"nonce"` StorageHash common.Hash `json:"storageHash"` StorageProof []StorageResult `json:"storageProof"` }
AccountResult struct for account proof
type AddrLocker ¶
type AddrLocker struct {
// contains filtered or unexported fields
}
AddrLocker is a mutex structure used to avoid querying outdated account data
func (*AddrLocker) LockAddr ¶
func (l *AddrLocker) LockAddr(address common.Address)
LockAddr locks an account's mutex. This is used to prevent another txs getting the same nonce until the lock is released. The mutex prevents the (an identical nonce) from being read again during the time that the first txs is being signed.
func (*AddrLocker) UnlockAddr ¶
func (l *AddrLocker) UnlockAddr(address common.Address)
UnlockAddr unlocks the mutex of the given account.
type Block ¶
type Block struct {
// contains filtered or unexported fields
}
func EthBlockToBlock ¶
func (*Block) Transaction ¶
func (b *Block) Transaction(hash common.Hash) *ethtypes.Transaction
func (*Block) Transactions ¶
func (b *Block) Transactions() ethtypes.Transactions
func (*Block) Withdrawals ¶
func (b *Block) Withdrawals() ethtypes.Withdrawals
type BlockNumber ¶
type BlockNumber int64
BlockNumber represents decoding hex string to block values
func NewBlockNumber ¶
func NewBlockNumber(n *big.Int) BlockNumber
NewBlockNumber creates a new BlockNumber instance.
func (BlockNumber) Int64 ¶
func (bn BlockNumber) Int64() int64
Int64 converts block number to primitive type
func (BlockNumber) TmHeight ¶
func (bn BlockNumber) TmHeight() *int64
TmHeight is a util function used for the Tendermint RPC client. It returns nil if the block number is "latest". Otherwise, it returns the pointer of the int64 value of the height.
func (*BlockNumber) UnmarshalJSON ¶
func (bn *BlockNumber) UnmarshalJSON(data []byte) error
UnmarshalJSON parses the given JSON fragment into a BlockNumber. It supports: - "latest", "finalized", "earliest" or "pending" as string arguments - the block number Returned errors: - an invalid block number error when the given argument isn't a known strings - an out of range error when the given block number is either too little or too large
type BlockNumberOrHash ¶
type BlockNumberOrHash struct { BlockNumber *BlockNumber `json:"blockNumber,omitempty"` BlockHash *common.Hash `json:"blockHash,omitempty"` }
BlockNumberOrHash represents a block number or a block hash.
func (*BlockNumberOrHash) UnmarshalJSON ¶
func (bnh *BlockNumberOrHash) UnmarshalJSON(data []byte) error
type EventFormat ¶
type EventFormat int
EventFormat is the format version of the events.
To fix the issue of txs exceeds block gas limit, we changed the event format in a breaking way. But to avoid forcing clients to re-sync from scatch, we make json-rpc logic to be compatible with both formats.
type FeeHistoryResult ¶
type NetworkingStack ¶
type NetworkingStack interface { // IsExtRPCEnabled returns true if the networking stack is configured to expose JSON-RPC APIs. ExtRPCEnabled() bool // RegisterHandler manually registers a new handler into the networking stack. RegisterHandler(string, string, http.Handler) // RegisterAPIs registers JSON-RPC handlers for the networking stack. RegisterAPIs([]rpc.API) // Start starts the networking stack. Start() error }
NetworkingStack defines methods that allow a Polaris chain to build and expose JSON-RPC apis.
type OneFeeHistory ¶
type OverrideAccount ¶
type OverrideAccount struct { Nonce *hexutil.Uint64 `json:"nonce"` Code *hexutil.Bytes `json:"code"` Balance **hexutil.Big `json:"balance"` State *map[common.Hash]common.Hash `json:"states"` StateDiff *map[common.Hash]common.Hash `json:"stateDiff"` }
OverrideAccount indicates the overriding fields of account during the execution of a message call. Note, states and stateDiff can't be specified at the same time. If states is set, message execution will only use the data in the given states. Otherwise if statDiff is set, all diff will be applied first and then execute the call message.
type ParsedTx ¶
type ParsedTx struct { MsgIndex int Hash common.Hash // -1 means uninitialized EthTxIndex int32 GasUsed uint64 Failed bool }
ParsedTx is the txs infos parsed from events.
type ParsedTxs ¶
type ParsedTxs struct { // one item per message Txs []ParsedTx // map txs hash to msg index TxHashes map[common.Hash]int }
ParsedTxs is the txs infos parsed from eth txs events.
func ParseTxResult ¶
ParseTxResult parse eth txs infos from cosmos-sdk events. It supports two event formats, the formats are described in the comments of the format constants.
func (*ParsedTxs) AccumulativeGasUsed ¶
AccumulativeGasUsed calculates the accumulated gas used within the batch of txs
func (*ParsedTxs) GetTxByHash ¶
GetTxByHash find ParsedTx by txs hash, returns nil if not exists.
func (*ParsedTxs) GetTxByMsgIndex ¶
GetTxByMsgIndex returns ParsedTx by msg index
func (*ParsedTxs) GetTxByTxIndex ¶
GetTxByTxIndex returns ParsedTx by txs index
type QueryClient ¶
type QueryClient struct { tx.ServiceClient evmtypes.QueryClient FeeMarket feetypes.QueryClient }
QueryClient defines a gRPC Client used for:
- Transaction simulation
- EVM module queries
- Fee market module queries
func NewQueryClient ¶
func NewQueryClient(clientCtx client.Context) *QueryClient
NewQueryClient creates a new gRPC query client
func (QueryClient) GetProof ¶
func (QueryClient) GetProof(clientCtx client.Context, storeKey string, key []byte) ([]byte, *crypto.ProofOps, error)
GetProof performs an ABCI query with the given key and returns a merkle proof. The desired tendermint height to perform the query should be set in the client context. The query will be performed at one below this height (at the IAVL version) in order to obtain the correct merkle proof. Proof queries at height less than or equal to 2 are not supported. Issue: https://github.com/cosmos/cosmos-sdk/issues/6567
type RPCTransaction ¶
type RPCTransaction 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"` GasFeeCap *hexutil.Big `json:"maxFeePerGas,omitempty"` GasTipCap *hexutil.Big `json:"maxPriorityFeePerGas,omitempty"` 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"` Type hexutil.Uint64 `json:"type"` Accesses *ethtypes.AccessList `json:"accessList,omitempty"` ChainID *hexutil.Big `json:"chainId,omitempty"` V *hexutil.Big `json:"v"` R *hexutil.Big `json:"r"` S *hexutil.Big `json:"s"` }
RPCTransaction represents a txs that will serialize to the RPC representation of a txs
func NewRPCTransaction ¶
func NewRPCTransaction( tx *ethtypes.Transaction, blockHash common.Hash, blockNumber, index uint64, baseFee *big.Int, chainID *big.Int, ) (*RPCTransaction, error)
NewTransactionFromData returns a txs that will serialize to the RPC representation, with the given location metadata set (if available).
func NewTransactionFromMsg ¶
func NewTransactionFromMsg( msg *evmtypes.MsgEthereumTx, blockHash common.Hash, blockNumber, index uint64, baseFee *big.Int, chainID *big.Int, ) (*RPCTransaction, error)
NewTransactionFromMsg returns a txs that will serialize to the RPC representation, with the given location metadata set (if available).
type SignTransactionResult ¶
type SignTransactionResult struct { Raw hexutil.Bytes `json:"raw"` Tx *ethtypes.Transaction `json:"txs"` }
SignTransactionResult represents a RLP encoded signed txs.
type StateOverride ¶
type StateOverride map[common.Address]OverrideAccount
StateOverride is the collection of overridden accounts.