rpcservices

package
v0.0.0-...-1f8a15b Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2023 License: GPL-3.0 Imports: 26 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) AddPeer 

func (back *RemoteBackend) AddPeer(ctx context.Context, request *remote.AddPeerRequest) (*remote.AddPeerReply, error)

func (*RemoteBackend) BadHeaderNumber 

func (back *RemoteBackend) BadHeaderNumber(ctx context.Context, tx kv.Getter, hash common.Hash) (blockNum *uint64, err error)

func (*RemoteBackend) BlockByHash 

func (back *RemoteBackend) BlockByHash(ctx context.Context, db kv.Tx, hash common.Hash) (*types.Block, error)

func (*RemoteBackend) BlockByNumber 

func (back *RemoteBackend) BlockByNumber(ctx context.Context, db kv.Tx, number uint64) (*types.Block, error)

func (*RemoteBackend) BlockWithSenders 

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

func (*RemoteBackend) Body 

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

func (*RemoteBackend) BodyRlp 

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

func (*RemoteBackend) BodyWithTransactions 

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

func (*RemoteBackend) BorSnapshots 

func (back *RemoteBackend) BorSnapshots() services.BlockSnapshots

func (*RemoteBackend) CanPruneTo 

func (back *RemoteBackend) CanPruneTo(currentBlockInDB uint64) (canPruneBlocksTo uint64)

func (*RemoteBackend) CanonicalHash 

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

func (*RemoteBackend) ClientVersion 

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

func (*RemoteBackend) CurrentBlock 

func (back *RemoteBackend) CurrentBlock(db kv.Tx) (*types.Block, error)

func (*RemoteBackend) EnsureVersionCompatibility 

func (back *RemoteBackend) EnsureVersionCompatibility() bool

func (*RemoteBackend) Etherbase 

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

func (*RemoteBackend) EventLookup 

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

func (*RemoteBackend) EventsByBlock 

func (back *RemoteBackend) EventsByBlock(ctx context.Context, tx kv.Tx, hash common.Hash, blockNum uint64) ([]rlp.RawValue, error)

func (*RemoteBackend) FreezingCfg 

func (back *RemoteBackend) FreezingCfg() ethconfig.BlocksFreezing

func (*RemoteBackend) FrozenBlocks 

func (back *RemoteBackend) FrozenBlocks() uint64

func (*RemoteBackend) FrozenBorBlocks 

func (back *RemoteBackend) FrozenBorBlocks() uint64

func (*RemoteBackend) FrozenFiles 

func (back *RemoteBackend) FrozenFiles() (list []string)

func (*RemoteBackend) HasSenders 

func (back *RemoteBackend) HasSenders(ctx context.Context, tx kv.Getter, hash common.Hash, blockNum uint64) (bool, error)

func (*RemoteBackend) Header 

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

func (*RemoteBackend) HeaderByHash 

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

func (*RemoteBackend) HeaderByNumber 

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

func (*RemoteBackend) HeadersRange 

func (back *RemoteBackend) HeadersRange(ctx context.Context, walker func(header *types.Header) error) 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) RawTransactions 

func (back *RemoteBackend) RawTransactions(ctx context.Context, tx kv.Getter, fromBlock, toBlock uint64) (txs [][]byte, err error)

func (*RemoteBackend) ReadAncestor 

func (back *RemoteBackend) ReadAncestor(db kv.Getter, hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)

func (*RemoteBackend) Snapshots 

func (back *RemoteBackend) Snapshots() services.BlockSnapshots

func (*RemoteBackend) Span 

func (back *RemoteBackend) Span(ctx context.Context, tx kv.Getter, spanId uint64) ([]byte, 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) TxnLookup 

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

func (*RemoteBackend) TxsV3Enabled 

func (back *RemoteBackend) TxsV3Enabled() bool

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.