fetcher

Documentation

Index

• func Cleaner()
• func GetRequest() uint64
• func IsRequest(id uint64, from *peer.Peer) bool
• func NewRequest(id uint64, from *peer.Peer) uint64
• func RequestBlockBodys(p *peer.Peer, number uint64, hash []common.Hash) error
• func RequestBlockHeader(p *peer.Peer, number uint64) error
• func RequestTxs(p *peer.Peer, txs []common.Hash) error
• func SendAnnounceTxs(p *peer.Peer, txs []common.Hash) error
• func SendBlockBodies(p *peer.Peer, bodys []*packet.BlockBody, requestId uint64) error
• func SendBlockHeaders(p *peer.Peer, headers []*types.Header, requestId uint64) error
• func SendPooledTxs(p *peer.Peer, txs []*types.Transaction, requestId uint64) error
• type Request

Functions

func Cleaner

func Cleaner()

func GetRequest

func GetRequest() uint64

func IsRequest

func IsRequest(id uint64, from *peer.Peer) bool

func NewRequest

func NewRequest(id uint64, from *peer.Peer) uint64

func RequestBlockBodys

func RequestBlockBodys(p *peer.Peer, number uint64, hash []common.Hash) error

func RequestBlockHeader

func RequestBlockHeader(p *peer.Peer, number uint64) error

func RequestTxs

func RequestTxs(p *peer.Peer, txs []common.Hash) error

func SendAnnounceTxs

func SendAnnounceTxs(p *peer.Peer, txs []common.Hash) error

func SendBlockBodies

func SendBlockBodies(p *peer.Peer, bodys []*packet.BlockBody, requestId uint64) error

func SendBlockHeaders

func SendBlockHeaders(p *peer.Peer, headers []*types.Header, requestId uint64) error

func SendPooledTxs

func SendPooledTxs(p *peer.Peer, txs []*types.Transaction, requestId uint64) error

Types

type Request

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