peer_protocol

Documentation

Index

• Constants
• type Bytes
  • func (b Bytes) MarshalBinary() ([]byte, error)
• type Decoder
  • func (d *Decoder) Decode(msg *Message) (err error)
• type Integer
  • func (i *Integer) Read(r io.Reader) error
• type Message
  • func (msg Message) MarshalBinary() (data []byte, err error)
• type MessageType

Constants

const (
	Choke         MessageType = iota
	Unchoke                   // 1
	Interested                // 2
	NotInterested             // 3
	Have                      // 4
	Bitfield                  // 5
	Request                   // 6
	Piece                     // 7
	Cancel                    // 8
	Port                      // 9

	// BEP 6
	Suggest     = 0xd  // 13
	HaveAll     = 0xe  // 14
	HaveNone    = 0xf  // 15
	Reject      = 0x10 // 16
	AllowedFast = 0x11 // 17

	Extended = 20

	HandshakeExtendedID = 0

	RequestMetadataExtensionMsgType = 0
	DataMetadataExtensionMsgType    = 1
	RejectMetadataExtensionMsgType  = 2
)

const (
	Protocol = "\x13BitTorrent protocol"
)

Types

type Bytes

type Bytes []byte

func (Bytes) MarshalBinary

func (b Bytes) MarshalBinary() ([]byte, error)

type Decoder

type Decoder struct {
	R         *bufio.Reader
	MaxLength Integer // TODO: Should this include the length header or not?
}

func (*Decoder) Decode

func (d *Decoder) Decode(msg *Message) (err error)

io.EOF is returned if the source terminates cleanly on a message boundary.

type Integer

type Integer uint32

func (*Integer) Read

func (i *Integer) Read(r io.Reader) error

type Message

type Message struct {
	Keepalive            bool
	Type                 MessageType
	Index, Begin, Length Integer
	Piece                []byte
	Bitfield             []bool
	ExtendedID           byte
	ExtendedPayload      []byte
	Port                 uint16
}

func (Message) MarshalBinary

func (msg Message) MarshalBinary() (data []byte, err error)

type MessageType

type MessageType byte