Versions in this module Expand all Collapse all v1 v1.6.2 Mar 2, 2021 v1.6.1 Mar 2, 2021 Changes in this version + type Message struct + Message interface{} + type Peer struct + Bitfield *bitfield.Bitfield + ClientChoking bool + ClientInterested bool + ConnectedAt time.Time + DHTEnabled bool + Downloading bool + EncryptionCipher mse.CryptoMethod + ExtensionHandshake *peerprotocol.ExtensionHandshakeMessage + ExtensionsEnabled bool + FastEnabled bool + ID [20]byte + Messages []interface{} + OptimisticUnchoked bool + PEX *pex + PeerChoking bool + PeerInterested bool + ReceivedAllowedFast pieceset.PieceSet + SentAllowedFast pieceset.PieceSet + Snubbed bool + Source peersource.Source + func New(conn net.Conn, source peersource.Source, id [20]byte, extensions [8]byte, ...) *Peer + func (p *Peer) CancelPiece(index, begin, length uint32) + func (p *Peer) Choke() + func (p *Peer) Choking() bool + func (p *Peer) Client() string + func (p *Peer) Close() + func (p *Peer) Done() chan struct{} + func (p *Peer) DownloadSpeed() int + func (p *Peer) EnabledFast() bool + func (p *Peer) GenerateAndSendAllowedFastMessages(k int, numPieces uint32, infoHash [20]byte, pieces []piece.Piece) + func (p *Peer) Interested() bool + func (p *Peer) MetadataSize() uint32 + func (p *Peer) Optimistic() bool + func (p *Peer) RequestMetadataPiece(index uint32) + func (p *Peer) RequestPiece(index, begin, length uint32) + func (p *Peer) ResetSnubTimer() + func (p *Peer) Run(messages chan Message, pieces chan interface{}, snubbed, disconnect chan *Peer) + func (p *Peer) SetOptimistic(value bool) + func (p *Peer) StartPEX(initialPeers map[*Peer]struct{}, recentlySeen *pexlist.RecentlySeen) + func (p *Peer) StopSnubTimer() + func (p *Peer) Unchoke() + func (p *Peer) UploadSpeed() int + type PieceMessage struct + Piece peerreader.Piece