rpcservices

package
v3.0.0-alpha5.0...-c974331 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2024 License: LGPL-3.0 Imports: 29 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) AllTypes 

func (back *RemoteBackend) AllTypes() []snaptype.Type

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, txCount 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() snapshotsync.BlockSnapshots

func (*RemoteBackend) BorStartEventId 

func (back *RemoteBackend) BorStartEventId(ctx context.Context, tx kv.Tx, hash common.Hash, blockNum uint64) (uint64, error)

func (*RemoteBackend) CanPruneTo 

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

func (*RemoteBackend) CanonicalBodyForStorage 

func (back *RemoteBackend) CanonicalBodyForStorage(ctx context.Context, tx kv.Getter, blockNum uint64) (body *types.BodyForStorage, err error)

func (*RemoteBackend) CanonicalHash 

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

func (*RemoteBackend) Checkpoint 

func (r *RemoteBackend) Checkpoint(ctx context.Context, tx kv.Tx, spanId uint64) (*heimdall.Checkpoint, bool, 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.Tx, 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) FirstTxnNumNotInSnapshots 

func (back *RemoteBackend) FirstTxnNumNotInSnapshots() uint64

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) HeaderNumber 

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

func (*RemoteBackend) HeadersRange 

func (back *RemoteBackend) HeadersRange(ctx context.Context, walker func(header *types.Header) error) error

func (*RemoteBackend) Integrity 

func (back *RemoteBackend) Integrity(_ context.Context) error

func (*RemoteBackend) IsCanonical 

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

func (*RemoteBackend) IterateFrozenBodies 

func (back *RemoteBackend) IterateFrozenBodies(_ func(blockNum uint64, baseTxNum uint64, txCount uint64) error) error

func (*RemoteBackend) LastCheckpointId 

func (r *RemoteBackend) LastCheckpointId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

func (*RemoteBackend) LastEventId 

func (back *RemoteBackend) LastEventId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

func (*RemoteBackend) LastFrozenEventBlockNum 

func (back *RemoteBackend) LastFrozenEventBlockNum() uint64

func (*RemoteBackend) LastFrozenEventId 

func (back *RemoteBackend) LastFrozenEventId() uint64

func (*RemoteBackend) LastFrozenSpanId 

func (back *RemoteBackend) LastFrozenSpanId() uint64

func (*RemoteBackend) LastMilestoneId 

func (r *RemoteBackend) LastMilestoneId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

func (*RemoteBackend) LastSpanId 

func (back *RemoteBackend) LastSpanId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

func (*RemoteBackend) Milestone 

func (r *RemoteBackend) Milestone(ctx context.Context, tx kv.Tx, spanId uint64) (*heimdall.Milestone, bool, 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) Ready 

func (back *RemoteBackend) Ready(ctx context.Context) <-chan error

func (*RemoteBackend) Snapshots 

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

func (*RemoteBackend) Span 

func (back *RemoteBackend) Span(ctx context.Context, tx kv.Tx, spanId uint64) (*heimdall.Span, bool, 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.