Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

torrent

package module

Go to main page

Versions in this module

v1

v1.2.0

Jun 19, 2019

v1.1.9

Jun 19, 2019

v1.1.8

Jun 9, 2019

v1.1.8-nolog

Jun 19, 2019

v1.1.7

Jun 9, 2019

Changes in this version

+ const PiecePriorityHigh

+ const PiecePriorityNext

+ const PiecePriorityNone

+ const PiecePriorityNormal

+ const PiecePriorityNow

+ const PiecePriorityReadahead

+ var DefaultHTTPUserAgent = "Go-Torrent/1.0"

+ func LoopbackListenHost(network string) string

+ func NewUtpSocket(network, addr string, fc firewallCallback) (utpSocket, error)

+ type Client struct

+ func NewClient(cfg *ClientConfig) (cl *Client, err error)

+ func (cl *Client) AddDHTNodes(nodes []string)

+ func (cl *Client) AddMagnet(uri string) (T *Torrent, err error)

+ func (cl *Client) AddTorrent(mi *metainfo.MetaInfo) (T *Torrent, err error)

+ func (cl *Client) AddTorrentFromFile(filename string) (T *Torrent, err error)

+ func (cl *Client) AddTorrentInfoHash(infoHash metainfo.Hash) (t *Torrent, new bool)

+ func (cl *Client) AddTorrentInfoHashWithStorage(infoHash metainfo.Hash, specStorage storage.ClientImpl) (t *Torrent, new bool)

+ func (cl *Client) AddTorrentSpec(spec *TorrentSpec) (t *Torrent, new bool, err error)

+ func (cl *Client) BadPeerIPs() []string

+ func (cl *Client) Close()

+ func (cl *Client) Closed() <-chan struct{}

+ func (cl *Client) DhtServers() []*dht.Server

+ func (cl *Client) ListenAddrs() (ret []net.Addr)

+ func (cl *Client) LocalPort() (port int)

+ func (cl *Client) PeerID() PeerID

+ func (cl *Client) Torrent(ih metainfo.Hash) (t *Torrent, ok bool)

+ func (cl *Client) Torrents() []*Torrent

+ func (cl *Client) WaitAll() bool

+ func (cl *Client) WriteStatus(_w io.Writer)

+ type ClientConfig struct

+ Bep20 string

+ ConnTracker *conntrack.Instance

+ DataDir string

+ Debug bool

+ DefaultStorage storage.ClientImpl

+ DhtStartingNodes dht.StartingNodesGetter

+ DisableAcceptRateLimiting bool

+ DisableAggressiveUpload bool

+ DisableIPv4 bool

+ DisableIPv4Peers bool

+ DisableIPv6 bool

+ DisablePEX bool

+ DisableTCP bool

+ DisableTrackers bool

+ DisableUTP bool

+ DownloadRateLimiter *rate.Limiter

+ EstablishedConnsPerTorrent int

+ ExtendedHandshakeClientVersion string

+ HTTPProxy func(*http.Request) (*url.URL, error)

+ HTTPUserAgent string

+ HalfOpenConnsPerTorrent int

+ HandshakesTimeout time.Duration

+ IPBlocklist iplist.Ranger

+ ListenHost func(network string) string

+ ListenPort int

+ MinDialTimeout time.Duration

+ NoDHT bool

+ NoDefaultPortForwarding bool

+ NoUpload bool

+ NominalDialTimeout time.Duration

+ PeerID string

+ ProxyURL string

+ PublicIp4 net.IP

+ PublicIp6 net.IP

+ Seed bool

+ TorrentPeersHighWater int

+ TorrentPeersLowWater int

+ UploadRateLimiter *rate.Limiter

+ func NewDefaultClientConfig() *ClientConfig

+ func (cfg *ClientConfig) SetListenAddr(addr string) *ClientConfig

+ type ConnStats struct

+ BytesRead Count

+ BytesReadData Count

+ BytesReadUsefulData Count

+ BytesWritten Count

+ BytesWrittenData Count

+ ChunksRead Count

+ ChunksReadUseful Count

+ ChunksReadWasted Count

+ ChunksWritten Count

+ MetadataChunksRead Count

+ PiecesDirtiedBad Count

+ PiecesDirtiedGood Count

+ func (me *ConnStats) Copy() (ret ConnStats)

+ type Count struct

+ func (me *Count) Add(n int64)

+ func (me *Count) Int64() int64

+ func (me *Count) String() string

+ type EncryptionPolicy struct

+ DisableEncryption bool

+ ForceEncryption bool

+ PreferNoEncryption bool

+ type File struct

+ func (f *File) Cancel()

+ func (f *File) DisplayPath() string

+ func (f *File) Download()

+ func (f *File) Length() int64

+ func (f *File) NewReader() Reader

+ func (f *File) Offset() int64

+ func (f *File) Priority() piecePriority

+ func (f *File) SetPriority(prio piecePriority)

+ func (f *File) State() (ret []FilePieceState)

+ func (f *File) Torrent() *Torrent

+ func (f File) FileInfo() metainfo.FileInfo

+ func (f File) Path() string

+ type FilePieceState struct

+ Bytes int64

+ type Handle interface

+ type InfoHash = metainfo.Hash

+ type IpPort = missinggo.IpPort

+ type Peer struct

+ IP net.IP

+ Id [20]byte

+ Port int

+ Source peerSource

+ SupportsEncryption bool

+ func (me *Peer) FromPex(na krpc.NodeAddr, fs peer_protocol.PexPeerFlags)

+ type PeerExtensionBits = pp.PeerExtensionBits

+ type PeerID [20]byte

+ type Peers []Peer

+ func (me *Peers) AppendFromPex(nas []krpc.NodeAddr, fs []peer_protocol.PexPeerFlags)

+ func (ret Peers) AppendFromTracker(ps []tracker.Peer) Peers

+ type Piece struct

+ func (p *Piece) Info() metainfo.Piece

+ func (p *Piece) SetPriority(prio piecePriority)

+ func (p *Piece) Storage() storage.Piece

+ func (p *Piece) String() string

+ func (p *Piece) VerifyData()

+ type PieceState struct

+ Checking bool

+ Partial bool

+ Priority piecePriority

+ type PieceStateChange struct

+ Index int

+ type PieceStateRun struct

+ Length int

+ type Reader interface

+ SetReadahead func(int64)

+ SetResponsive func()

+ type Torrent struct

+ func (t *Torrent) AddClientPeer(cl *Client)

+ func (t *Torrent) AddPeers(pp []Peer)

+ func (t *Torrent) AddTrackers(announceList [][]string)

+ func (t *Torrent) BytesCompleted() int64

+ func (t *Torrent) BytesMissing() int64

+ func (t *Torrent) CancelPieces(begin, end pieceIndex)

+ func (t *Torrent) Closed() <-chan struct{}

+ func (t *Torrent) DownloadAll()

+ func (t *Torrent) DownloadPieces(begin, end pieceIndex)

+ func (t *Torrent) Drop()

+ func (t *Torrent) Files() []*File

+ func (t *Torrent) GotInfo() <-chan struct{}

+ func (t *Torrent) Info() *metainfo.Info

+ func (t *Torrent) InfoHash() metainfo.Hash

+ func (t *Torrent) KnownSwarm() (ks []Peer)

+ func (t *Torrent) Length() int64

+ func (t *Torrent) Metainfo() metainfo.MetaInfo

+ func (t *Torrent) Name() string

+ func (t *Torrent) NewReader() Reader

+ func (t *Torrent) NumPieces() pieceIndex

+ func (t *Torrent) Piece(i pieceIndex) *Piece

+ func (t *Torrent) PieceBytesMissing(piece int) int64

+ func (t *Torrent) PieceState(piece pieceIndex) PieceState

+ func (t *Torrent) PieceStateRuns() []PieceStateRun

+ func (t *Torrent) Seeding() bool

+ func (t *Torrent) SetDisplayName(dn string)

+ func (t *Torrent) SetInfoBytes(b []byte) (err error)

+ func (t *Torrent) SetMaxEstablishedConns(max int) (oldMax int)

+ func (t *Torrent) Stats() TorrentStats

+ func (t *Torrent) String() string

+ func (t *Torrent) SubscribePieceStateChanges() *pubsub.Subscription

+ func (t *Torrent) VerifyData()

+ type TorrentSpec struct

+ ChunkSize int

+ DisplayName string

+ InfoBytes []byte

+ InfoHash metainfo.Hash

+ Storage storage.ClientImpl

+ Trackers [][]string

+ func TorrentSpecFromMagnetURI(uri string) (spec *TorrentSpec, err error)

+ func TorrentSpecFromMetaInfo(mi *metainfo.MetaInfo) (spec *TorrentSpec)

+ type TorrentStats struct

+ ActivePeers int

+ ConnectedSeeders int

+ HalfOpenPeers int

+ PendingPeers int

+ TotalPeers int