p2p

May 5, 2023

Changes in this version

+ type DialFunc func(ctx context.Context, net, addr string) (net.Conn, error)

type LocalPeer

+ func (lp *LocalPeer) SetDialFunc(dial DialFunc)

Jan 20, 2022

Changes in this version

+ const Pver

+ var ErrDisconnected = errors.New("peer has been disconnected")

+ var ErrNotFound = errors.E(errors.NotExist, "transaction not found")

+ func UseLogger(l slog.Logger)

+ type LocalPeer struct

+ func NewLocalPeer(params *chaincfg.Params, extaddr *net.TCPAddr, amgr *addrmgr.AddrManager) *LocalPeer

+ func (lp *LocalPeer) AddHandledMessages(mask MessageMask)

+ func (lp *LocalPeer) AddrManager() *addrmgr.AddrManager

+ func (lp *LocalPeer) ConnectOutbound(ctx context.Context, addr string, reqSvcs wire.ServiceFlag) (*RemotePeer, error)

+ func (lp *LocalPeer) ReceiveGetData(ctx context.Context) (*RemotePeer, *wire.MsgGetData, error)

+ func (lp *LocalPeer) ReceiveHeadersAnnouncement(ctx context.Context) (*RemotePeer, []*wire.BlockHeader, error)

+ func (lp *LocalPeer) ReceiveInv(ctx context.Context) (*RemotePeer, *wire.MsgInv, error)

+ func (lp *LocalPeer) RemoveHandledMessages(mask MessageMask)

+ func (lp *LocalPeer) RequirePeerHeight(requiredHeight int32)

+ func (lp *LocalPeer) SeedPeers(ctx context.Context, services wire.ServiceFlag)

+ type MessageMask uint64

+ const MaskGetData

+ const MaskInv

+ type RemotePeer struct

+ func (rp *RemotePeer) Addrs(ctx context.Context) error

+ func (rp *RemotePeer) BanScore() uint32

+ func (rp *RemotePeer) Block(ctx context.Context, blockHash *chainhash.Hash) (*wire.MsgBlock, error)

+ func (rp *RemotePeer) Blocks(ctx context.Context, blockHashes []*chainhash.Hash) ([]*wire.MsgBlock, error)

+ func (rp *RemotePeer) CFilterV2(ctx context.Context, blockHash *chainhash.Hash) (*gcs.FilterV2, uint32, []chainhash.Hash, error)

+ func (rp *RemotePeer) CFiltersV2(ctx context.Context, blockHashes []*chainhash.Hash) ([]filterProof, error)

+ func (rp *RemotePeer) Disconnect(reason error)

+ func (rp *RemotePeer) Err() error

+ func (rp *RemotePeer) Headers(ctx context.Context, blockLocators []*chainhash.Hash, hashStop *chainhash.Hash) ([]*wire.BlockHeader, error)

+ func (rp *RemotePeer) HeadersAsync(ctx context.Context, blockLocators []*chainhash.Hash, hashStop *chainhash.Hash) error

+ func (rp *RemotePeer) ID() uint64

+ func (rp *RemotePeer) InitialHeight() int32

+ func (rp *RemotePeer) InvsRecv() *lru.Cache

+ func (rp *RemotePeer) InvsSent() *lru.Cache

+ func (rp *RemotePeer) KnownHeaders() *lru.Cache

+ func (rp *RemotePeer) LocalAddr() net.Addr

+ func (rp *RemotePeer) NA() *addrmgr.NetAddress

+ func (rp *RemotePeer) PublishTransactions(ctx context.Context, txs ...*wire.MsgTx) error

+ func (rp *RemotePeer) Pver() uint32

+ func (rp *RemotePeer) ReceivedOrphanHeader() error

+ func (rp *RemotePeer) RemoteAddr() net.Addr

+ func (rp *RemotePeer) SendHeaders(ctx context.Context) error

+ func (rp *RemotePeer) SendHeadersSent() bool

+ func (rp *RemotePeer) SendMessage(ctx context.Context, msg wire.Message) error

+ func (rp *RemotePeer) Services() wire.ServiceFlag

+ func (rp *RemotePeer) String() string

+ func (rp *RemotePeer) Transactions(ctx context.Context, hashes []*chainhash.Hash) ([]*wire.MsgTx, error)

+ func (rp *RemotePeer) UA() string