Versions in this module Expand all Collapse all v1 v1.0.0 Dec 13, 2022 Changes in this version + var ErrBlockNotFound = errors.New("block not found") + var ErrTransactionNotFound = errors.New("transaction not found") + func ContextWithRequestID(parent context.Context, id jsonrpc.ID) context.Context + type Client interface + BlockByHash func(ctx context.Context, hash string, full bool) (*eth.Block, error) + BlockByNumber func(ctx context.Context, number uint64, full bool) (*eth.Block, error) + BlockByNumberOrTag func(ctx context.Context, numberOrTag eth.BlockNumberOrTag, full bool) (*eth.Block, error) + BlockNumber func(ctx context.Context) (uint64, error) + ChainId func(ctx context.Context) (string, error) + EstimateGas func(ctx context.Context, msg eth.Transaction) (uint64, error) + GasPrice func(ctx context.Context) (uint64, error) + GetTransactionCount func(ctx context.Context, address eth.Address, numberOrTag eth.BlockNumberOrTag) (uint64, error) + IsBidirectional func() bool + Logs func(ctx context.Context, filter eth.LogFilter) ([]eth.Log, error) + MaxPriorityFeePerGas func(ctx context.Context) (uint64, error) + NetPeerCount func(ctx context.Context) (uint64, error) + NetVersion func(ctx context.Context) (string, error) + SendRawTransaction func(ctx context.Context, msg string) (string, error) + SubscribeNewHeads func(ctx context.Context) (Subscription, error) + SubscribeNewPendingTransactions func(ctx context.Context) (Subscription, error) + Syncing func(ctx context.Context) (bool, error) + TransactionByHash func(ctx context.Context, hash string) (*eth.Transaction, error) + TransactionReceipt func(ctx context.Context, hash string) (*eth.TransactionReceipt, error) + URL func() string + func NewClient(ctx context.Context, rawURL string) (Client, error) + func NewCustomClient(requester Requester, subscriber Subscriber) (Client, error) + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *MockClient + func (m *MockClient) BlockByHash(ctx context.Context, hash string, full bool) (*eth.Block, error) + func (m *MockClient) BlockByNumber(ctx context.Context, number uint64, full bool) (*eth.Block, error) + func (m *MockClient) BlockByNumberOrTag(ctx context.Context, numberOrTag eth.BlockNumberOrTag, full bool) (*eth.Block, error) + func (m *MockClient) BlockNumber(ctx context.Context) (uint64, error) + func (m *MockClient) ChainId(ctx context.Context) (string, error) + func (m *MockClient) EXPECT() *MockClientMockRecorder + func (m *MockClient) EstimateGas(ctx context.Context, msg eth.Transaction) (uint64, error) + func (m *MockClient) GasPrice(ctx context.Context) (uint64, error) + func (m *MockClient) GetTransactionCount(ctx context.Context, address eth.Address, numberOrTag eth.BlockNumberOrTag) (uint64, error) + func (m *MockClient) IsBidirectional() bool + func (m *MockClient) Logs(ctx context.Context, filter eth.LogFilter) ([]eth.Log, error) + func (m *MockClient) MaxPriorityFeePerGas(ctx context.Context) (uint64, error) + func (m *MockClient) NetPeerCount(ctx context.Context) (string, error) + func (m *MockClient) NetVersion(ctx context.Context) (string, error) + func (m *MockClient) Request(ctx context.Context, r *jsonrpc.Request) (*jsonrpc.RawResponse, error) + func (m *MockClient) SendRawTransaction(ctx context.Context, msg string) (string, error) + func (m *MockClient) Subscribe(ctx context.Context, r *jsonrpc.Request) (Subscription, error) + func (m *MockClient) SubscribeNewHeads(ctx context.Context) (Subscription, error) + func (m *MockClient) SubscribeNewPendingTransactions(ctx context.Context) (Subscription, error) + func (m *MockClient) TransactionByHash(ctx context.Context, hash string) (*eth.Transaction, error) + func (m *MockClient) TransactionReceipt(ctx context.Context, hash string) (*eth.TransactionReceipt, error) + func (m *MockClient) URL() string + type MockClientMockRecorder struct + func (mr *MockClientMockRecorder) BlockByHash(ctx, hash, full interface{}) *gomock.Call + func (mr *MockClientMockRecorder) BlockByNumber(ctx, number, full interface{}) *gomock.Call + func (mr *MockClientMockRecorder) BlockByNumberOrTag(ctx, numberOrTag, full interface{}) *gomock.Call + func (mr *MockClientMockRecorder) BlockNumber(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) ChainId(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) EstimateGas(ctx, msg interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GasPrice(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetTransactionCount(ctx, address, numberOrTag interface{}) *gomock.Call + func (mr *MockClientMockRecorder) IsBidirectional() *gomock.Call + func (mr *MockClientMockRecorder) Logs(ctx, filter interface{}) *gomock.Call + func (mr *MockClientMockRecorder) MaxPriorityFeePerGas(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) NetPeerCount(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) NetVersion(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Request(ctx, r interface{}) *gomock.Call + func (mr *MockClientMockRecorder) SendRawTransaction(ctx, msg interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Subscribe(ctx, r interface{}) *gomock.Call + func (mr *MockClientMockRecorder) SubscribeNewHeads(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) SubscribeNewPendingTransactions(ctx interface{}) *gomock.Call + func (mr *MockClientMockRecorder) TransactionByHash(ctx, hash interface{}) *gomock.Call + func (mr *MockClientMockRecorder) TransactionReceipt(ctx, hash interface{}) *gomock.Call + func (mr *MockClientMockRecorder) URL() *gomock.Call + type MockRequester struct + func NewMockRequester(ctrl *gomock.Controller) *MockRequester + func (m *MockRequester) EXPECT() *MockRequesterMockRecorder + func (m *MockRequester) Request(ctx context.Context, r *jsonrpc.Request) (*jsonrpc.RawResponse, error) + type MockRequesterMockRecorder struct + func (mr *MockRequesterMockRecorder) Request(ctx, r interface{}) *gomock.Call + type MockSubscriber struct + func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber + func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder + func (m *MockSubscriber) Subscribe(ctx context.Context, r *jsonrpc.Request) (Subscription, error) + type MockSubscriberMockRecorder struct + func (mr *MockSubscriberMockRecorder) Subscribe(ctx, r interface{}) *gomock.Call + type MockSubscription struct + func NewMockSubscription(ctrl *gomock.Controller) *MockSubscription + func (m *MockSubscription) Ch() <-chan *jsonrpc.Notification + func (m *MockSubscription) EXPECT() *MockSubscriptionMockRecorder + func (m *MockSubscription) ID() string + func (m *MockSubscription) Response() *jsonrpc.RawResponse + func (m *MockSubscription) Unsubscribe(ctx context.Context) error + type MockSubscriptionMockRecorder struct + func (mr *MockSubscriptionMockRecorder) Ch() *gomock.Call + func (mr *MockSubscriptionMockRecorder) ID() *gomock.Call + func (mr *MockSubscriptionMockRecorder) Response() *gomock.Call + func (mr *MockSubscriptionMockRecorder) Unsubscribe(ctx interface{}) *gomock.Call + type Requester interface + Request func(ctx context.Context, r *jsonrpc.Request) (*jsonrpc.RawResponse, error) + type Subscriber interface + Subscribe func(ctx context.Context, r *jsonrpc.Request) (Subscription, error) + type Subscription interface + Ch func() <-chan *jsonrpc.Notification + ID func() string + Response func() *jsonrpc.RawResponse + Unsubscribe func(ctx context.Context) error + type SubscriptionParams struct + Result json.RawMessage + Subscription string