Versions in this module Expand all Collapse all v1 v1.1.1 Feb 22, 2026 v1.1.0 Feb 19, 2026 Changes in this version + const Blocks + const EarliestBlockNumber + const LatestBlockNumber + const NoIndexInHeap + const PendingBlockNumber + const PendingTransactions + const StatusAlreadyQueued + const StatusPaused + const StatusQueued + const StatusScheduled + var ErrBlockNotFound = errors.New("block not found") + var ErrBlockRangeTooHigh = errors.New("block range too high") + var ErrCastingFilterToLogFilter = errors.New("casting filter object to logFilter error") + var ErrExecutionTimeout = errors.New("execution timeout") + var ErrFailedFetchGenesis = errors.New("error fetching genesis block header") + var ErrFilterNotFound = errors.New("filter not found") + var ErrHeaderNotFound = errors.New("header not found") + var ErrIncorrectBlockRange = errors.New("incorrect range") + var ErrInsufficientFunds = errors.New("insufficient funds for execution") + var ErrLatestNotFound = errors.New("latest header not found") + var ErrNegativeBlockNumber = errors.New("invalid argument 0: block number must not be negative") + var ErrNoConfig = errors.New("missing config object") + var ErrNoDataInContractCreation = errors.New("contract creation without data provided") + var ErrNoWSConnection = errors.New("no websocket connection") + var ErrStateNotFound = errors.New("given root and slot not found in storage") + var ErrTraceGenesisBlock = errors.New("genesis is not traceable") + var ErrUnknownSubscriptionType = errors.New("unknown subscription type") + var ErrWSFilterDoesNotSupportGetChanges = errors.New("web socket Filter doesn't support to return a batch of the changes") + func DecodeTxn(arg *txnArgs, blockNumber uint64, store nonceGetter, forceSetNonce bool) (*types.Transaction, error) + func GetBlockHeader(number BlockNumber, store headerGetter) (*types.Header, error) + func GetHeaderFromBlockNumberOrHash(bnh BlockNumberOrHash, store blockGetter) (*types.Header, error) + func GetNextNonce(address types.Address, number BlockNumber, store nonceGetter) (uint64, error) + func GetNumericBlockNumber(number BlockNumber, store latestHeaderGetter) (uint64, error) + func GetTxAndBlockByTxHash(txHash types.Hash, store txLookupAndBlockGetter) (*types.Transaction, *types.Block) + func NewInternalError(msg string) *internalError + func NewInvalidParamsError(msg string) *invalidParamsError + func NewInvalidRequestError(msg string) *invalidRequestError + func NewMethodNotFoundError(method string) *methodNotFoundError + func NewSubscriptionNotFoundError(method string) *subscriptionNotFoundError + type Account struct + Balance *big.Int + Nonce uint64 + type BatchRequest []Request + type BlockNumber int64 + func (b *BlockNumber) UnmarshalJSON(buffer []byte) error + type BlockNumberOrHash struct + BlockHash *types.Hash + BlockNumber *BlockNumber + func (bnh *BlockNumberOrHash) UnmarshalJSON(data []byte) error + type Bridge struct + func (b *Bridge) GenerateExitProof(exitID argUint64) (interface{}, error) + func (b *Bridge) GetStateSyncProof(stateSyncID argUint64) (interface{}, error) + type Config struct + AccessControlAllowOrigin []string + Addr *net.TCPAddr + BatchLengthLimit uint64 + BlockRangeLimit uint64 + ChainID uint64 + ChainName string + ConcurrentRequestsDebug uint64 + PriceLimit uint64 + Store JSONRPCStore + WebSocketReadLimit uint64 + type ContentResponse struct + Pending map[types.Address]map[uint64]*transaction + Queued map[types.Address]map[uint64]*transaction + type Debug struct + func NewDebug(store debugStore, requestsPerSecond uint64) *Debug + func (d *Debug) TraceBlock(input string, config *TraceConfig) (interface{}, error) + func (d *Debug) TraceBlockByHash(blockHash types.Hash, config *TraceConfig) (interface{}, error) + func (d *Debug) TraceBlockByNumber(blockNumber BlockNumber, config *TraceConfig) (interface{}, error) + func (d *Debug) TraceCall(arg *txnArgs, filter BlockNumberOrHash, config *TraceConfig) (interface{}, error) + func (d *Debug) TraceTransaction(txHash types.Hash, config *TraceConfig) (interface{}, error) + type Dispatcher struct + func (d *Dispatcher) Handle(reqBody []byte) ([]byte, error) + func (d *Dispatcher) HandleWs(reqBody []byte, conn wsConn) ([]byte, error) + func (d *Dispatcher) RemoveFilterByWs(conn wsConn) + type Error interface + Error func() string + ErrorCode func() int + type ErrorResponse struct + Error *ObjectError + ID interface{} + JSONRPC string + func (e *ErrorResponse) Bytes() ([]byte, error) + func (e *ErrorResponse) Data() json.RawMessage + func (e *ErrorResponse) GetID() interface{} + type Eth struct + func (e *Eth) BlockNumber() (interface{}, error) + func (e *Eth) Call(arg *txnArgs, filter BlockNumberOrHash, apiOverride *stateOverride) (interface{}, error) + func (e *Eth) ChainId() (interface{}, error) + func (e *Eth) EstimateGas(arg *txnArgs, rawNum *BlockNumber) (interface{}, error) + func (e *Eth) FeeHistory(blockCount argUint64, newestBlock BlockNumber, rewardPercentiles []float64) (interface{}, error) + func (e *Eth) GasPrice() (interface{}, error) + func (e *Eth) GetBalance(address types.Address, filter BlockNumberOrHash) (interface{}, error) + func (e *Eth) GetBlockByHash(hash types.Hash, fullTx bool) (interface{}, error) + func (e *Eth) GetBlockByNumber(number BlockNumber, fullTx bool) (interface{}, error) + func (e *Eth) GetBlockTransactionCountByNumber(number BlockNumber) (interface{}, error) + func (e *Eth) GetCode(address types.Address, filter BlockNumberOrHash) (interface{}, error) + func (e *Eth) GetFilterChanges(id string) (interface{}, error) + func (e *Eth) GetFilterLogs(id string) (interface{}, error) + func (e *Eth) GetLogs(query *LogQuery) (interface{}, error) + func (e *Eth) GetStorageAt(address types.Address, index types.Hash, filter BlockNumberOrHash) (interface{}, error) + func (e *Eth) GetTransactionByHash(hash types.Hash) (interface{}, error) + func (e *Eth) GetTransactionCount(address types.Address, filter BlockNumberOrHash) (interface{}, error) + func (e *Eth) GetTransactionReceipt(hash types.Hash) (interface{}, error) + func (e *Eth) MaxPriorityFeePerGas() (interface{}, error) + func (e *Eth) NewBlockFilter() (interface{}, error) + func (e *Eth) NewFilter(filter *LogQuery) (interface{}, error) + func (e *Eth) SendRawTransaction(buf argBytes) (interface{}, error) + func (e *Eth) SendTransaction(_ *txnArgs) (interface{}, error) + func (e *Eth) Syncing() (interface{}, error) + func (e *Eth) UninstallFilter(id string) (bool, error) + func (e *Eth) Unsubscribe(id string) (bool, error) + type FilterManager struct + func NewFilterManager(logger hclog.Logger, store filterManagerStore, blockRangeLimit uint64) *FilterManager + func (f *FilterManager) Close() + func (f *FilterManager) Exists(id string) bool + func (f *FilterManager) GetFilterChanges(id string) (interface{}, error) + func (f *FilterManager) GetLogFilterFromID(filterID string) (*logFilter, error) + func (f *FilterManager) GetLogsForQuery(query *LogQuery) ([]*Log, error) + func (f *FilterManager) NewBlockFilter(ws wsConn) string + func (f *FilterManager) NewLogFilter(logQuery *LogQuery, ws wsConn) string + func (f *FilterManager) NewPendingTxFilter(ws wsConn) string + func (f *FilterManager) RemoveFilterByWs(ws wsConn) + func (f *FilterManager) Run() + func (f *FilterManager) Uninstall(id string) bool + type GetResponse struct + ChainID uint64 + Name string + Version string + type InspectResponse struct + CurrentCapacity uint64 + MaxCapacity uint64 + Pending map[string]map[string]string + Queued map[string]map[string]string + type JSONRPC struct + func NewJSONRPC(logger hclog.Logger, config *Config) (*JSONRPC, error) + type JSONRPCStore interface + type Log struct + Address types.Address + BlockHash types.Hash + BlockNumber argUint64 + Data argBytes + LogIndex argUint64 + Removed bool + Topics []types.Hash + TxHash types.Hash + TxIndex argUint64 + type LogQuery struct + Addresses []types.Address + BlockHash *types.Hash + Topics [][]types.Hash + func (q *LogQuery) Match(log *types.Log) bool + func (q *LogQuery) UnmarshalJSON(data []byte) error + type Net struct + func (n *Net) Listening() (interface{}, error) + func (n *Net) PeerCount() (interface{}, error) + func (n *Net) Version() (interface{}, error) + type ObjectError struct + Code int + Data interface{} + Message string + func (e *ObjectError) Error() string + func (e *ObjectError) MarshalJSON() ([]byte, error) + type Request struct + ID interface{} + Method string + Params json.RawMessage + type Response interface + Bytes func() ([]byte, error) + Data func() json.RawMessage + GetID func() interface{} + func NewRPCErrorResponse(id interface{}, errCode int, err string, data []byte, jsonrpcver string) Response + func NewRPCResponse(id interface{}, jsonrpcver string, reply []byte, err Error) Response + type StatusResponse struct + Pending uint64 + Queued uint64 + type SuccessResponse struct + Error *ObjectError + ID interface{} + JSONRPC string + Result json.RawMessage + func (s *SuccessResponse) Bytes() ([]byte, error) + func (s *SuccessResponse) Data() json.RawMessage + func (s *SuccessResponse) GetID() interface{} + type Throttling struct + func NewThrottling(maximumConcurrentRequests uint64, timeout time.Duration) *Throttling + func (t *Throttling) AttemptRequest(parentCtx context.Context, requestHandler func() (interface{}, error)) (interface{}, error) + type TraceConfig struct + DisableStack bool + DisableStorage bool + DisableStructLogs bool + EnableMemory bool + EnableReturnData bool + Timeout *string + Tracer string + type TxPool struct + func (t *TxPool) Content() (interface{}, error) + func (t *TxPool) Inspect() (interface{}, error) + func (t *TxPool) Status() (interface{}, error) + type Web3 struct + func (w *Web3) ClientVersion() (interface{}, error) + func (w *Web3) Sha3(v argBytes) (interface{}, error)
Go to main page