rpcservices

package
v0.0.0-...-92d349b Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2023 License: GPL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MiningService 

type MiningService struct {
	txpool.MiningClient
	// contains filtered or unexported fields
}

func NewMiningService 

func NewMiningService(client txpool.MiningClient) *MiningService

func (*MiningService) EnsureVersionCompatibility 

func (s *MiningService) EnsureVersionCompatibility() bool

type RemoteBackend 

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

func NewRemoteBackend 

func NewRemoteBackend(client remote.ETHBACKENDClient, db kv.RoDB, blockReader services.FullBlockReader) *RemoteBackend

func (*RemoteBackend) BlockWithSenders 

func (back *RemoteBackend) BlockWithSenders(ctx context.Context, tx kv.Getter, hash libcommon.Hash, blockHeight uint64) (block *types.Block, senders []libcommon.Address, err error)

func (*RemoteBackend) Body 

func (back *RemoteBackend) Body(ctx context.Context, tx kv.Getter, hash libcommon.Hash, blockHeight uint64) (body *types.Body, txAmount uint32, err error)

func (*RemoteBackend) BodyRlp 

func (back *RemoteBackend) BodyRlp(ctx context.Context, tx kv.Getter, hash libcommon.Hash, blockHeight uint64) (bodyRlp rlp.RawValue, err error)

func (*RemoteBackend) BodyWithTransactions 

func (back *RemoteBackend) BodyWithTransactions(ctx context.Context, tx kv.Getter, hash libcommon.Hash, blockHeight uint64) (body *types.Body, err error)

func (*RemoteBackend) CanonicalHash 

func (back *RemoteBackend) CanonicalHash(ctx context.Context, tx kv.Getter, blockHeight uint64) (libcommon.Hash, error)

func (*RemoteBackend) ClientVersion 

func (back *RemoteBackend) ClientVersion(ctx context.Context) (string, error)

func (*RemoteBackend) EngineForkchoiceUpdated 

func (back *RemoteBackend) EngineForkchoiceUpdated(ctx context.Context, request *remote.EngineForkChoiceUpdatedRequest) (*remote.EngineForkChoiceUpdatedResponse, error)

func (*RemoteBackend) EngineGetPayload 

func (back *RemoteBackend) EngineGetPayload(ctx context.Context, payloadId uint64) (res *remote.EngineGetPayloadResponse, err error)

func (*RemoteBackend) EngineGetPayloadBodiesByHashV1 

func (back *RemoteBackend) EngineGetPayloadBodiesByHashV1(ctx context.Context, request *remote.EngineGetPayloadBodiesByHashV1Request) (*remote.EngineGetPayloadBodiesV1Response, error)

func (*RemoteBackend) EngineGetPayloadBodiesByRangeV1 

func (back *RemoteBackend) EngineGetPayloadBodiesByRangeV1(ctx context.Context, request *remote.EngineGetPayloadBodiesByRangeV1Request) (*remote.EngineGetPayloadBodiesV1Response, error)

func (*RemoteBackend) EngineNewPayload 

func (back *RemoteBackend) EngineNewPayload(ctx context.Context, payload *types2.ExecutionPayload) (res *remote.EnginePayloadStatus, err error)

func (*RemoteBackend) EnsureVersionCompatibility 

func (back *RemoteBackend) EnsureVersionCompatibility() bool

func (*RemoteBackend) Etherbase 

func (back *RemoteBackend) Etherbase(ctx context.Context) (libcommon.Address, error)

func (*RemoteBackend) Header 

func (back *RemoteBackend) Header(ctx context.Context, tx kv.Getter, hash libcommon.Hash, blockHeight uint64) (*types.Header, error)

func (*RemoteBackend) HeaderByHash 

func (back *RemoteBackend) HeaderByHash(ctx context.Context, tx kv.Getter, hash libcommon.Hash) (*types.Header, error)

func (*RemoteBackend) HeaderByNumber 

func (back *RemoteBackend) HeaderByNumber(ctx context.Context, tx kv.Getter, blockHeight uint64) (*types.Header, error)

func (*RemoteBackend) NetPeerCount 

func (back *RemoteBackend) NetPeerCount(ctx context.Context) (uint64, error)

func (*RemoteBackend) NetVersion 

func (back *RemoteBackend) NetVersion(ctx context.Context) (uint64, error)

func (*RemoteBackend) NodeInfo 

func (back *RemoteBackend) NodeInfo(ctx context.Context, limit uint32) ([]p2p.NodeInfo, error)

func (*RemoteBackend) Peers 

func (back *RemoteBackend) Peers(ctx context.Context) ([]*p2p.PeerInfo, error)

func (*RemoteBackend) PendingBlock 

func (back *RemoteBackend) PendingBlock(ctx context.Context) (*types.Block, error)

func (*RemoteBackend) ProtocolVersion 

func (back *RemoteBackend) ProtocolVersion(ctx context.Context) (uint64, error)

func (*RemoteBackend) Subscribe 

func (back *RemoteBackend) Subscribe(ctx context.Context, onNewEvent func(*remote.SubscribeReply)) error

func (*RemoteBackend) SubscribeLogs 

func (back *RemoteBackend) SubscribeLogs(ctx context.Context, onNewLogs func(reply *remote.SubscribeLogsReply), requestor *atomic.Value) error

func (*RemoteBackend) TxnByIdxInBlock 

func (back *RemoteBackend) TxnByIdxInBlock(ctx context.Context, tx kv.Getter, blockNum uint64, i int) (types.Transaction, error)

func (*RemoteBackend) TxnEffectiveGasPricePercentage 

func (back *RemoteBackend) TxnEffectiveGasPricePercentage(ctx context.Context, tx kv.Tx, txnHash libcommon.Hash) (uint8, error)

func (*RemoteBackend) TxnLookup 

func (back *RemoteBackend) TxnLookup(ctx context.Context, tx kv.Getter, txnHash libcommon.Hash) (uint64, bool, error)

type TxPoolService 

type TxPoolService struct {
	txpooproto.TxpoolClient
	// contains filtered or unexported fields
}

func NewTxPoolService 

func NewTxPoolService(client txpooproto.TxpoolClient) *TxPoolService

func (*TxPoolService) EnsureVersionCompatibility 

func (s *TxPoolService) EnsureVersionCompatibility() bool

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.