9 // Marshalled as binary by the UDP client, so be careful making changes.
10 type AnnounceRequest struct {
19 NumWant int32 // How many peer addresses are desired. -1 for default.
23 type AnnounceResponse struct {
24 Interval int32 // Minimum seconds the local peer should wait before next announce.
30 type AnnounceEvent int32
32 func (me AnnounceEvent) String() string {
33 // See BEP 3, "event".
34 return []string{"empty", "completed", "started", "stopped"}[me]
43 None AnnounceEvent = iota
44 Completed // The local peer just completed the torrent.
45 Started // The local peer has just resumed this torrent.
46 Stopped // The local peer is leaving the swarm.
49 type Client interface {
50 // Returns ErrNotConnected if Connect needs to be called.
51 Announce(*AnnounceRequest) (AnnounceResponse, error)
58 ErrNotConnected = errors.New("not connected")
59 ErrBadScheme = errors.New("unknown scheme")
61 schemes = make(map[string]func(*url.URL) Client)
64 func RegisterClientScheme(scheme string, newFunc func(*url.URL) Client) {
65 schemes[scheme] = newFunc
68 // Returns ErrBadScheme if the tracker scheme isn't recognised.
69 func New(rawurl string) (cl Client, err error) {
70 url_s, err := url.Parse(rawurl)
74 newFunc, ok := schemes[url_s.Scheme]