Versions in this module Expand all Collapse all v0 v0.0.38 May 15, 2024 Changes in this version + const GasUsedRatio + const JwtExpiryTimeout + const LatestCtxHeight + const LocalAddress + const NewHeadsListenerBuffer + const SleepInterval + const SubscriberPrefix + const TxSearchPerPage + const UnconfirmedTxQueryMaxPage + const UnconfirmedTxQueryPerPage + var BitMasks = [8]uint8 + var DefaultConfig = Config + func CalculatePercentiles(rewardPercentiles []float64, GasAndRewards []GasAndReward, ...) []*hexutil.Big + func CheckPath(r *http.Request, path string) bool + func CheckTimeouts(timeouts *rpc.HTTPTimeouts) + func CheckVersion(ctx sdk.Context, k *keeper.Keeper) error + func EncodeFilters(addresses []common.Address, topics [][]common.Hash) (res [][]bloomIndexes) + func EncodeTmBlock(ctx sdk.Context, block *coretypes.ResultBlock, ...) (map[string]interface{}, error) + func FullBloom() ethtypes.Bloom + func GetBlockNumberByNrOrHash(ctx context.Context, tmClient rpcclient.Client, ...) (*int64, error) + func GetEvmTxIndex(txs tmtypes.Txs, txIndex uint32, decoder sdk.TxDecoder) (index int, found bool) + func MatchFilters(bloom ethtypes.Bloom, filters [][]bloomIndexes) bool + func NewGzipHandler(next http.Handler) http.Handler + func NewHTTPHandlerStack(srv http.Handler, cors []string, vhosts []string, JwtSecret []byte) http.Handler + func NewWSConnectionHandler(handler http.Handler) http.Handler + func NewWSHandlerStack(srv http.Handler, JwtSecret []byte) http.Handler + func RegisterApis(logger log.Logger, apis []rpc.API, modules []string, srv *rpc.Server) error + func StartHTTPEndpoint(endpoint string, timeouts rpc.HTTPTimeouts, handler http.Handler) (*http.Server, net.Addr, error) + type AccessListResult struct + Accesslist *ethtypes.AccessList + Error string + GasUsed hexutil.Uint64 + type AssociateRequest struct + CustomMessage string + R string + S string + V string + type AssociationAPI struct + func NewAssociationAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *AssociationAPI + func (t *AssociationAPI) Associate(ctx context.Context, req *AssociateRequest) (returnErr error) + func (t *AssociationAPI) GetEVMAddress(_ context.Context, seiAddress string) (result string, returnErr error) + func (t *AssociationAPI) GetSeiAddress(_ context.Context, ethAddress common.Address) (result string, returnErr error) + type Backend struct + func NewBackend(ctxProvider func(int64) sdk.Context, keeper *keeper.Keeper, ...) *Backend + func (b *Backend) ChainConfig() *params.ChainConfig + func (b *Backend) ChainDb() ethdb.Database + func (b *Backend) CurrentHeader() *ethtypes.Header + func (b *Backend) Engine() consensus.Engine + func (b *Backend) GetEVM(_ context.Context, msg *core.Message, stateDB vm.StateDB, _ *ethtypes.Header, ...) *vm.EVM + func (b *Backend) GetPoolNonce(_ context.Context, addr common.Address) (uint64, error) + func (b *Backend) GetTransaction(ctx context.Context, txHash common.Hash) (tx *ethtypes.Transaction, blockHash common.Hash, blockNumber uint64, ...) + func (b *Backend) HeaderByNumber(ctx context.Context, bn rpc.BlockNumber) (*ethtypes.Header, error) + func (b *Backend) RPCEVMTimeout() time.Duration + func (b *Backend) RPCGasCap() uint64 + func (b *Backend) StateAndHeaderByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (vm.StateDB, *ethtypes.Header, error) + func (b *Backend) StateAtBlock(ctx context.Context, block *ethtypes.Block, reexec uint64, base vm.StateDB, ...) (vm.StateDB, tracers.StateReleaseFunc, error) + func (b *Backend) StateAtTransaction(ctx context.Context, block *ethtypes.Block, txIndex int, reexec uint64) (*ethtypes.Transaction, vm.BlockContext, vm.StateDB, tracers.StateReleaseFunc, ...) + func (b *Backend) SuggestGasTipCap(context.Context) (*big.Int, error) + func (b Backend) BlockByHash(ctx context.Context, hash common.Hash) (*ethtypes.Block, error) + func (b Backend) BlockByNumber(ctx context.Context, bn rpc.BlockNumber) (*ethtypes.Block, error) + type BlockAPI struct + func NewBlockAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *BlockAPI + func (a *BlockAPI) GetBlockByHash(ctx context.Context, blockHash common.Hash, fullTx bool) (result map[string]interface{}, returnErr error) + func (a *BlockAPI) GetBlockByNumber(ctx context.Context, number rpc.BlockNumber, fullTx bool) (result map[string]interface{}, returnErr error) + func (a *BlockAPI) GetBlockReceipts(ctx context.Context, number rpc.BlockNumber) (result []map[string]interface{}, returnErr error) + func (a *BlockAPI) GetBlockTransactionCountByHash(ctx context.Context, blockHash common.Hash) (result *hexutil.Uint, returnErr error) + func (a *BlockAPI) GetBlockTransactionCountByNumber(ctx context.Context, number rpc.BlockNumber) (result *hexutil.Uint, returnErr error) + type Config struct + CORSOrigins string + CheckTxTimeout time.Duration + DenyList []string + EnableTestAPI bool + FilterTimeout time.Duration + HTTPEnabled bool + HTTPPort int + IdleTimeout time.Duration + MaxBlocksForLog int64 + MaxLogNoBlock int64 + MaxSubscriptionsNewHead uint64 + MaxTxPoolTxs uint64 + ReadHeaderTimeout time.Duration + ReadTimeout time.Duration + SimulationEVMTimeout time.Duration + SimulationGasLimit uint64 + Slow bool + WSEnabled bool + WSOrigins string + WSPort int + WriteTimeout time.Duration + func ReadConfig(opts servertypes.AppOptions) (Config, error) + type ConnectionType string + var ConnectionTypeHTTP ConnectionType = "http" + var ConnectionTypeWS ConnectionType = "websocket" + type DebugAPI struct + func NewDebugAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *DebugAPI + func (api *DebugAPI) TraceBlockByHash(ctx context.Context, hash common.Hash, config *tracers.TraceConfig) (interface{}, error) + func (api *DebugAPI) TraceBlockByNumber(ctx context.Context, number rpc.BlockNumber, config *tracers.TraceConfig) (interface{}, error) + func (api *DebugAPI) TraceTransaction(ctx context.Context, hash common.Hash, config *tracers.TraceConfig) (interface{}, error) + type EVMServer interface + Start func() error + func NewEVMHTTPServer(logger log.Logger, config Config, tmClient rpcclient.Client, k *keeper.Keeper, ...) (EVMServer, error) + func NewEVMWebSocketServer(logger log.Logger, config Config, tmClient rpcclient.Client, k *keeper.Keeper, ...) (EVMServer, error) + type EchoAPI struct + func NewEchoAPI() *EchoAPI + func (a *EchoAPI) Echo(data string) string + type Engine struct + func (e *Engine) Author(*ethtypes.Header) (common.Address, error) + type EventItemDataWrapper struct + Type string + Value json.RawMessage + type FeeHistoryResult struct + BaseFee []*hexutil.Big + GasUsedRatio []float64 + OldestBlock *hexutil.Big + Reward [][]*hexutil.Big + type FilterAPI struct + func NewFilterAPI(tmClient rpcclient.Client, logFetcher *LogFetcher, filterConfig *FilterConfig, ...) *FilterAPI + func (a *FilterAPI) GetFilterChanges(ctx context.Context, filterID ethrpc.ID) (res interface{}, err error) + func (a *FilterAPI) GetFilterLogs(ctx context.Context, filterID ethrpc.ID) (res []*ethtypes.Log, err error) + func (a *FilterAPI) GetLogs(ctx context.Context, crit filters.FilterCriteria) (res []*ethtypes.Log, err error) + func (a *FilterAPI) NewBlockFilter(_ context.Context) (id ethrpc.ID, err error) + func (a *FilterAPI) NewFilter(_ context.Context, crit filters.FilterCriteria) (id ethrpc.ID, err error) + func (a *FilterAPI) UninstallFilter(_ context.Context, filterID ethrpc.ID) (res bool) + type FilterConfig struct + type FilterType byte + const BlocksSubscription + const LogsSubscription + const UnknownSubscription + type GasAndReward struct + GasUsed uint64 + Reward *big.Int + type HTTPConfig struct + CorsAllowedOrigins []string + DenyList []string + Modules []string + Vhosts []string + type HTTPServer struct + HTTPConfig HTTPConfig + WsConfig WsConfig + func NewHTTPServer(log log.Logger, timeouts rpc.HTTPTimeouts) *HTTPServer + func (h *HTTPServer) EnableRPC(apis []rpc.API, config HTTPConfig) error + func (h *HTTPServer) EnableWS(apis []rpc.API, config WsConfig) error + func (h *HTTPServer) ListenAddr() string + func (h *HTTPServer) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (h *HTTPServer) SetListenAddr(host string, port int) error + func (h *HTTPServer) Start() error + func (h *HTTPServer) Stop() + type InfoAPI struct + func NewInfoAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *InfoAPI + func (i *InfoAPI) Accounts() (result []common.Address, returnErr error) + func (i *InfoAPI) BlockNumber() hexutil.Uint64 + func (i *InfoAPI) ChainId() *hexutil.Big + func (i *InfoAPI) Coinbase() (common.Address, error) + func (i *InfoAPI) FeeHistory(ctx context.Context, blockCount math.HexOrDecimal64, lastBlock rpc.BlockNumber, ...) (result *FeeHistoryResult, returnErr error) + func (i *InfoAPI) GasPrice(ctx context.Context) (result *hexutil.Big, returnErr error) + type LogFetcher struct + func (f *LogFetcher) FindBlockesByBloom(begin, end int64, filters [][]bloomIndexes) (res []int64) + func (f *LogFetcher) FindLogsByBloom(height int64, filters [][]bloomIndexes) (res []*ethtypes.Log) + func (f *LogFetcher) GetLogsByFilters(ctx context.Context, crit filters.FilterCriteria, lastToHeight int64) ([]*ethtypes.Log, int64, error) + func (f *LogFetcher) GetLogsForBlock(ctx context.Context, block *coretypes.ResultBlock, crit filters.FilterCriteria, ...) []*ethtypes.Log + func (f *LogFetcher) IsLogExactMatch(log *ethtypes.Log, crit filters.FilterCriteria) bool + type NetAPI struct + func NewNetAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *NetAPI + func (i *NetAPI) Version() string + type ProofResult struct + Address common.Address + HexValues []string + StorageProof []*crypto.ProofOps + type QueryBuilder struct + func NewBlockQueryBuilder() *QueryBuilder + func NewHeadQueryBuilder() *QueryBuilder + func (q *QueryBuilder) Build() string + type RPCEndpointConfig struct + JwtSecret []byte + type RevertError struct + func NewRevertError(result *core.ExecutionResult) *RevertError + func (e *RevertError) ErrorCode() int + func (e *RevertError) ErrorData() interface{} + type SendAPI struct + func NewSendAPI(tmClient rpcclient.Client, txConfig client.TxConfig, sendConfig *SendConfig, ...) *SendAPI + func (s *SendAPI) SendRawTransaction(ctx context.Context, input hexutil.Bytes) (hash common.Hash, err error) + func (s *SendAPI) SendTransaction(ctx context.Context, args ethapi.TransactionArgs) (result common.Hash, returnErr error) + func (s *SendAPI) SignTransaction(_ context.Context, args apitypes.SendTxArgs, _ *string) (result *ethapi.SignTransactionResult, returnErr error) + type SendConfig struct + type SimulateConfig struct + EVMTimeout time.Duration + GasCap uint64 + type SimulationAPI struct + func NewSimulationAPI(ctxProvider func(int64) sdk.Context, keeper *keeper.Keeper, ...) *SimulationAPI + func (s *SimulationAPI) Call(ctx context.Context, args ethapi.TransactionArgs, ...) (result hexutil.Bytes, returnErr error) + func (s *SimulationAPI) CreateAccessList(ctx context.Context, args ethapi.TransactionArgs, ...) (result *AccessListResult, returnErr error) + func (s *SimulationAPI) EstimateGas(ctx context.Context, args ethapi.TransactionArgs, ...) (result hexutil.Uint64, returnErr error) + type StateAPI struct + func NewStateAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *StateAPI + func (a *StateAPI) GetBalance(ctx context.Context, address common.Address, ...) (result *hexutil.Big, returnErr error) + func (a *StateAPI) GetCode(ctx context.Context, address common.Address, ...) (result hexutil.Bytes, returnErr error) + func (a *StateAPI) GetNonce(_ context.Context, address common.Address) uint64 + func (a *StateAPI) GetProof(ctx context.Context, address common.Address, storageKeys []string, ...) (result *ProofResult, returnErr error) + func (a *StateAPI) GetStorageAt(ctx context.Context, address common.Address, hexKey string, ...) (result hexutil.Bytes, returnErr error) + type SubInfo struct + Query string + SubscriptionCh <-chan coretypes.ResultEvent + type SubscriberID uint64 + type SubscriptionAPI struct + func NewSubscriptionAPI(tmClient rpcclient.Client, logFetcher *LogFetcher, ...) *SubscriptionAPI + func (a *SubscriptionAPI) Logs(ctx context.Context, filter *filters.FilterCriteria) (s *rpc.Subscription, err error) + func (a *SubscriptionAPI) NewHeads(ctx context.Context) (s *rpc.Subscription, err error) + type SubscriptionConfig struct + type SubscriptionManager struct + NextID SubscriberID + SubscriptionInfo map[SubscriberID]SubInfo + func NewSubscriptionManager(tmClient rpcclient.Client) *SubscriptionManager + func (s *SubscriptionManager) Subscribe(ctx context.Context, q *QueryBuilder, limit int) (SubscriberID, <-chan coretypes.ResultEvent, error) + func (s *SubscriptionManager) Unsubscribe(ctx context.Context, id SubscriberID) error + type TestAPI struct + func NewTestAPI() *TestAPI + func (a *TestAPI) IncrementPointerVersion(pointerType string, offset int16) error + type TransactionAPI struct + func NewTransactionAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *TransactionAPI + func (t *TransactionAPI) GetTransactionByBlockHashAndIndex(ctx context.Context, blockHash common.Hash, index hexutil.Uint) (result *ethapi.RPCTransaction, returnErr error) + func (t *TransactionAPI) GetTransactionByBlockNumberAndIndex(ctx context.Context, blockNr rpc.BlockNumber, index hexutil.Uint) (result *ethapi.RPCTransaction, returnErr error) + func (t *TransactionAPI) GetTransactionByHash(ctx context.Context, hash common.Hash) (result *ethapi.RPCTransaction, returnErr error) + func (t *TransactionAPI) GetTransactionCount(ctx context.Context, address common.Address, ...) (result *hexutil.Uint64, returnErr error) + func (t *TransactionAPI) GetTransactionErrorByHash(_ context.Context, hash common.Hash) (result string, returnErr error) + func (t *TransactionAPI) GetTransactionReceipt(ctx context.Context, hash common.Hash) (result map[string]interface{}, returnErr error) + func (t *TransactionAPI) GetVMError(hash common.Hash) (result string, returnErr error) + func (t *TransactionAPI) Sign(addr common.Address, data hexutil.Bytes) (result hexutil.Bytes, returnErr error) + type TxPoolAPI struct + func NewTxPoolAPI(tmClient rpcclient.Client, k *keeper.Keeper, ...) *TxPoolAPI + func (t *TxPoolAPI) Content(ctx context.Context) (result map[string]map[string]map[string]*ethapi.RPCTransaction, ...) + type TxPoolConfig struct + type Web3API struct + func (w *Web3API) ClientVersion() string + type WsConfig struct + Modules []string + Origins []string