torrent

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

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

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

type ByDownloadBPS []Choker

type ChokePolicy interface {
	// Only pass in interested peers.
	// mutate the chokers into a list where the first N are to be unchoked.
	Choke(chokers []Choker) (unchokeCount int, err error)
}

type Choker interface {
	DownloadBPS() float32 // bps
}

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

type ClientStatusReport struct {
	Event      string
	InfoHash   string
	PeerId     string
	Port       uint16
	Uploaded   uint64
	Downloaded uint64
	Left       uint64
}

type Dialer func(network, addr string) (net.Conn, error)

type ExtensionHandshake struct {
	M      map[string]int `bencode:"m"`
	P      uint16         `bencode:"p"`
	V      string         `bencode:"v"`
	Yourip string         `bencode:"yourip"`
	Ipv6   string         `bencode:"ipv6"`
	Ipv4   string         `bencode:"ipv4"`
	Reqq   uint16         `bencode:"reqq"`

	MetadataSize uint `bencode:"metadata_size"`
}

type File interface {
	io.ReaderAt
	io.WriterAt
	io.Closer
}

type FileDict struct {
	Length int64
	Path   []string
	Md5sum string
}

type FileStore interface {
	io.ReaderAt
	io.WriterAt
	io.Closer
}

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

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

type FileSystem interface {
	Open(name []string, length int64) (file File, err error)
}

type InfoDict struct {
	PieceLength int64 `bencode:"piece length"`
	Pieces      string
	Private     int64
	Name        string
	// Single File Mode
	Length int64
	Md5sum string
	// Multiple File mode
	Files []FileDict
}

type MetaDataExchange struct {
	Transferring bool
	Pieces       [][]byte
}

type MetaInfo struct {
	Info         InfoDict
	InfoHash     string
	Announce     string
	AnnounceList [][]string `bencode:"announce-list"`
	CreationDate string     `bencode:"creation date"`
	Comment      string
	CreatedBy    string `bencode:"created by"`
	Encoding     string
}

type MetaInfoFile interface {
	io.Closer
	io.Reader
	io.ReaderAt
	Readdirnames(n int) (names []string, err error)
	Stat() (os.FileInfo, error)
}

type MetaInfoFileSystem interface {
	Open(name string) (MetaInfoFile, error)
	Stat(name string) (os.FileInfo, error)
}

type MetadataMessage struct {
	MsgType   uint8 `bencode:"msg_type"`
	Piece     uint  `bencode:"piece"`
	TotalSize uint  `bencode:"total_size"`
}

type NeverChokePolicy struct{}

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

type SessionInfo struct {
	PeerId     string
	Port       uint16
	Uploaded   uint64
	Downloaded uint64
	Left       uint64

	HaveTorrent bool

	OurExtensions map[int]string
	ME            *MetaDataExchange
}

type TorrentClient struct {
	Flags      *TorrentFlags
	ListenPort int
	DoneConn   chan *TorrentSession
	Sessions   map[string]*TorrentSession
	// contains filtered or unexported fields
}

type TorrentFlags struct {
	Port                int
	FileDir             string
	SeedRatio           float64
	UseDeadlockDetector bool

	// The dial function to use. Nil means use net.Dial
	Dial Dialer
}

type TorrentSession struct {
	Done chan bool

	M *MetaInfo

	TorrentFile string
	// contains filtered or unexported fields
}

type TrackerResponse struct {
	FailureReason  string `bencode:"failure reason"`
	WarningMessage string `bencode:"warning message"`
	Interval       uint
	MinInterval    uint   `bencode:"min interval"`
	TrackerId      string `bencode:"tracker id"`
	Complete       uint
	Incomplete     uint
	Peers          string
	Peers6         string
}