tracker

Documentation

Index

• type Action
• type AnnounceRequest
  • func (r *AnnounceRequest) Bytes() ([]byte, error)
• type AnnounceResponse
• type ConnectRequest
  • func (request ConnectRequest) Bytes() []byte
• type ConnectResponse
• type Event
• type HTTPGetter
  • func (h *HTTPGetter) GetPeers(announce string, metafile models.Metafile) ([]models.Peer, error)
• type PeersGetter
  • func NewHTTPGetter(client *http.Client, peerID string) PeersGetter
  • func NewUDPGetter(peerID string) PeersGetter
• type Tracker
  • func NewTracker(announceURL, peerID string) Tracker
• type UDPGetter
  • func (u UDPGetter) GetPeers(announceURL string, metafile models.Metafile) ([]models.Peer, error)

Types

type Action

type Action uint32

const (
	ActionConnect  Action = 0
	ActionAnnounce Action = 1
)

type AnnounceRequest

type AnnounceRequest struct {
	ConnectionID  uint64
	Action        Action
	TransactionID uint32
	InfoHash      [20]byte
	PeerID        [20]byte
	Downloaded    uint64
	Left          uint64
	Uploaded      uint64
	Event         Event
	IP            uint32
	Key           uint32
	NumWant       uint32
	Port          uint16
}

func (*AnnounceRequest) Bytes

func (r *AnnounceRequest) Bytes() ([]byte, error)

type AnnounceResponse

type AnnounceResponse struct {
	Action        Action
	TransactionID uint32
	Interval      uint32
	Leechers      uint32
	Seeders       uint32
	Peers         []models.Peer
}

type ConnectRequest

type ConnectRequest struct {
	ProtocolID    uint64
	Action        Action
	TransactionID uint32
}

func (ConnectRequest) Bytes

func (request ConnectRequest) Bytes() []byte

type ConnectResponse

type ConnectResponse struct {
	Action        Action
	TransactionID uint32
	ConnectionID  uint64
}

type Event

type Event uint32

const (
	EventNone Event = iota
	EventCompleted
	EventStarted
	EventStopped
)

type HTTPGetter

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

func (*HTTPGetter) GetPeers

func (h *HTTPGetter) GetPeers(announce string, metafile models.Metafile) ([]models.Peer, error)

type PeersGetter

type PeersGetter interface {
	GetPeers(announce string, metafile models.Metafile) ([]models.Peer, error)
}

func NewHTTPGetter

func NewHTTPGetter(client *http.Client, peerID string) PeersGetter

func NewUDPGetter

func NewUDPGetter(peerID string) PeersGetter

type Tracker

type Tracker interface {
	GetPeers(models.Metafile) ([]models.Peer, error)
	WithHTTPClient(client *http.Client) Tracker
}

func NewTracker

func NewTracker(announceURL, peerID string) Tracker

type UDPGetter

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

func (UDPGetter) GetPeers

func (u UDPGetter) GetPeers(announceURL string, metafile models.Metafile) ([]models.Peer, error)