node

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2023 License: MIT Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrHeaderTraversalAheadOfProvider            = errors.New("the HeaderTraversal's internal state is ahead of the provider")
	ErrHeaderTraversalAndProviderMismatchedState = errors.New("the HeaderTraversal and provider have diverged in state")
)
View Source 
var (
	MetricsNamespace = "rpc"
)

Functions

This section is empty.

Types

type EthClient 

type EthClient interface {
	BlockHeaderByNumber(*big.Int) (*types.Header, error)
	BlockHeaderByHash(common.Hash) (*types.Header, error)
	BlockHeadersByRange(*big.Int, *big.Int) ([]types.Header, error)

	TxByHash(common.Hash) (*types.Transaction, error)

	StorageHash(common.Address, *big.Int) (common.Hash, error)
	FilterLogs(ethereum.FilterQuery) ([]types.Log, error)
}

func DialEthClient 

func DialEthClient(rpcUrl string, metrics Metricer) (EthClient, error)

type HeaderTraversal 

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

func NewHeaderTraversal 

func NewHeaderTraversal(ethClient EthClient, fromHeader *types.Header, confDepth *big.Int) *HeaderTraversal

NewHeaderTraversal instantiates a new instance of HeaderTraversal against the supplied rpc client. The HeaderTraversal will start fetching blocks starting from the supplied header unless nil, indicating genesis.

func (*HeaderTraversal) LastHeader added in v1.1.6 

func (f *HeaderTraversal) LastHeader() *types.Header

LastHeader returns the last header that was fetched by the HeaderTraversal This is useful for testing the state of the HeaderTraversal

func (*HeaderTraversal) NextFinalizedHeaders 

func (f *HeaderTraversal) NextFinalizedHeaders(maxSize uint64) ([]types.Header, error)

NextFinalizedHeaders retrives the next set of headers that have been marked as finalized by the connected client, bounded by the supplied size

type Metricer added in v1.1.6 

type Metricer interface {
	RecordRPCClientRequest(method string) func(err error)
	RecordRPCClientBatchRequest(b []rpc.BatchElem) func(err error)
}

func NewMetrics added in v1.1.6 

func NewMetrics(registry *prometheus.Registry, subsystem string) Metricer

type MockEthClient added in v1.1.6 

type MockEthClient struct {
	mock.Mock
}

func (*MockEthClient) BlockHeaderByHash added in v1.1.6 

func (m *MockEthClient) BlockHeaderByHash(hash common.Hash) (*types.Header, error)

func (*MockEthClient) BlockHeaderByNumber added in v1.1.6 

func (m *MockEthClient) BlockHeaderByNumber(number *big.Int) (*types.Header, error)

func (*MockEthClient) BlockHeadersByRange added in v1.1.6 

func (m *MockEthClient) BlockHeadersByRange(from, to *big.Int) ([]types.Header, error)

func (*MockEthClient) FilterLogs added in v1.1.6 

func (m *MockEthClient) FilterLogs(query ethereum.FilterQuery) ([]types.Log, error)

func (*MockEthClient) StorageHash added in v1.1.6 

func (m *MockEthClient) StorageHash(address common.Address, blockNumber *big.Int) (common.Hash, error)

func (*MockEthClient) TxByHash added in v1.1.6 

func (m *MockEthClient) TxByHash(hash common.Hash) (*types.Transaction, error)

type RPC added in v1.1.6 

type RPC interface {
	Close()
	CallContext(ctx context.Context, result any, method string, args ...any) error
	BatchCallContext(ctx context.Context, b []rpc.BatchElem) error
}

func NewRPC added in v1.2.0 

func NewRPC(client *rpc.Client, metrics Metricer) RPC

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.