peerwriter

Documentation

Index

• type BlockUploaded
• type PeerWriter
  • func New(conn net.Conn, l logger.Logger, maxQueuedRequests int, fastEnabled bool, ...) *PeerWriter
  • func (p *PeerWriter) CancelRequest(msg peerprotocol.CancelMessage)
  • func (p *PeerWriter) Done() chan struct{}
  • func (p *PeerWriter) Messages() <-chan interface{}
  • func (p *PeerWriter) Run()
  • func (p *PeerWriter) SendMessage(msg peerprotocol.Message)
  • func (p *PeerWriter) SendPiece(msg peerprotocol.RequestMessage, pi io.ReaderAt)
  • func (p *PeerWriter) Stop()
• type Piece
  • func (p Piece) ID() peerprotocol.MessageID
  • func (p Piece) Read(b []byte) (int, error)

Types

type BlockUploaded

type BlockUploaded struct {
	Length uint32
}

type PeerWriter

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

func New

func New(conn net.Conn, l logger.Logger, maxQueuedRequests int, fastEnabled bool, b *ratelimit.Bucket) *PeerWriter

func (*PeerWriter) CancelRequest

func (p *PeerWriter) CancelRequest(msg peerprotocol.CancelMessage)

func (*PeerWriter) Done

func (p *PeerWriter) Done() chan struct{}

func (*PeerWriter) Messages

func (p *PeerWriter) Messages() <-chan interface{}

func (*PeerWriter) Run

func (p *PeerWriter) Run()

func (*PeerWriter) SendMessage

func (p *PeerWriter) SendMessage(msg peerprotocol.Message)

func (*PeerWriter) SendPiece

func (p *PeerWriter) SendPiece(msg peerprotocol.RequestMessage, pi io.ReaderAt)

func (*PeerWriter) Stop

func (p *PeerWriter) Stop()

type Piece

type Piece struct {
	Data io.ReaderAt
	peerprotocol.RequestMessage
}

func (Piece) ID

func (p Piece) ID() peerprotocol.MessageID

func (Piece) Read

func (p Piece) Read(b []byte) (int, error)