torrent

Sep 9, 2024

Changes in this version

+ var ChunksReceived expvar.Map

Jun 3, 2024

Changes in this version

type AddTorrentOpts

+ InfoHashV2 g.Option[infohash_v2.T]

type Client

+ func (cl *Client) ICEServers() []webrtc.ICEServer

type ClientConfig

+ ICEServerList []webrtc.ICEServer

type File

+ func (f *File) String() string

+ type PiecePriority = types.PiecePriority

type PieceState

+ MissingPieceLayerHash bool

type Torrent

+ func (t *Torrent) AddPieceLayers(layers map[string]string) (errs []error)

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

type TorrentSpec

+ InfoHashV2 g.Option[infohash_v2.T]

+ PieceLayers map[string]string

Feb 28, 2024

Changes in this version

type Callbacks

+ PeerConnAdded []func(*PeerConn)

+ PeerConnReadExtensionMessage []func(PeerConnReadExtensionMessageEvent)

+ type LocalLtepProtocolMap struct

+ Index []pp.ExtensionName

+ NumBuiltin int

+ func (me *LocalLtepProtocolMap) AddUserProtocol(name pp.ExtensionName)

+ func (me *LocalLtepProtocolMap) LookupId(id pp.ExtensionNumber) (name pp.ExtensionName, builtin bool, err error)

type Peer

+ func (p *Peer) Close() error

type PeerConn

+ LocalLtepProtocolMap *LocalLtepProtocolMap

+ func (pc *PeerConn) WriteExtendedMessage(extName pp.ExtensionName, payload []byte) error

+ type PeerConnReadExtensionMessageEvent struct

+ ExtensionNumber pp.ExtensionNumber

+ Payload []byte

+ PeerConn *PeerConn

Oct 9, 2023

retracted

Changes in this version

type ClientConfig

+ PieceHashersPerTorrent int

+ WebTransport http.RoundTripper

Dec 5, 2023

retracted

Changes in this version

type Torrent

+ func (t *Torrent) WebseedPeerConns() []*Peer

May 28, 2023

retracted

Changes in this version

type ClientConfig

+ ICEServers []string

May 19, 2023

retracted

Changes in this version

+ const PeerSourceUtHolepunch

type Client

+ func (cl *Client) Stats() ClientStats

type ClientConfig

+ DialRateLimiter *rate.Limiter

+ type ClientStats struct

+ ActiveHalfOpenAttempts int

+ NumPeersDialableOnlyAfterHolepunch int

+ NumPeersDialedSuccessfullyAfterHolepunchConnect int

+ NumPeersProbablyOnlyConnectedDueToHolepunch int

+ NumPeersUndialableWithoutHolepunch int

+ NumPeersUndialableWithoutHolepunchDialedAfterHolepunchConnect int

type PeerConn

+ PeerListenPort int

Apr 4, 2023

retracted

Changes in this version

type AddTorrentOpts

+ InfoBytes []byte

+ type StringAddr string

+ func (StringAddr) Network() string

+ func (me StringAddr) String() string

Mar 19, 2023

retracted

Changes in this version

type ClientConfig

+ MaxAllocPeerRequestDataPerConn int64

type Peer

+ func (p *Peer) Torrent() *Torrent

Dec 25, 2022

retracted

Changes in this version

type ClientConfig

+ HTTPDialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ HttpRequestDirector func(*http.Request) error

+ WebsocketTrackerHttpHeader func() http.Header

+ type ClientDhtConfig struct

+ ConfigureAnacrolixDhtServer func(*dht.ServerConfig)

+ DHTOnQuery func(query *krpc.Msg, source net.Addr) (propagate bool)

+ DhtStartingNodes func(network string) dht.StartingNodesGetter

+ NoDHT bool

+ PeriodicallyAnnounceTorrentsToDht bool

+ type ClientTrackerConfig struct

+ DisableTrackers bool

+ LookupTrackerIp func(*url.URL) ([]net.IP, error)

+ TrackerDialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ TrackerListenPacket func(network, addr string) (net.PacketConn, error)

Sep 18, 2022

retracted

Changes in this version

type ClientConfig

+ TrackerDialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ TrackerListenPacket func(network, addr string) (net.PacketConn, error)

type Piece

+ func (p *Piece) Flush()

Jun 25, 2022

retracted

Changes in this version

type Client

+ func (cl *Client) PublicIPs() (ips []net.IP)

Jun 1, 2022

retracted

Changes in this version

type Peer

+ func (cn *Peer) DownloadRate() float64

May 12, 2022

retracted

Changes in this version

+ type AddWebSeedsOpt func(*webseed.Client)

+ func WebSeedPathEscaper(custom webseed.PathEscaper) AddWebSeedsOpt

Apr 11, 2022

retracted

Changes in this version

type File

+ func (f *File) BeginPieceIndex() int

+ func (f *File) EndPieceIndex() int

type Torrent

+ func (t *Torrent) AddWebSeeds(urls []string)

+ func (t *Torrent) UseSources(sources []string)

Nov 16, 2021

retracted

Changes in this version

+ type ReadaheadContext struct

+ ContiguousReadStartPos int64

+ CurrentPos int64

+ type ReadaheadFunc func(ReadaheadContext) int64

type Reader

+ SetReadaheadFunc func(ReadaheadFunc)

Nov 9, 2021

retracted

Changes in this version

+ type AddTorrentOpts struct

+ ChunkSize pp.Integer

+ InfoHash InfoHash

+ Storage storage.ClientImpl

Nov 1, 2021

retracted

Changes in this version

type ClientConfig

+ LookupTrackerIp func(*url.URL) ([]net.IP, error)

Oct 27, 2021

retracted

Changes in this version

type Client

+ func (cl *Client) AddTorrentOpt(opts addTorrentOpts) (t *Torrent, new bool)

type ClientConfig

+ MinPeerExtensions PeerExtensionBits

type Torrent

+ Complete chansync.Flag

type TorrentSpec

+ DisableInitialPieceCheck bool

type TorrentStats

+ PiecesComplete int

Sep 30, 2021

retracted

Changes in this version

type ClientConfig

+ AlwaysWantConns bool

+ type RequestIndex = request_strategy.RequestIndex

Aug 19, 2021

retracted

Changes in this version

type ClientConfig

+ KeepAliveTimeout time.Duration

Aug 13, 2021

retracted

Changes in this version

type TorrentSpec

+ func TorrentSpecFromMetaInfoErr(mi *metainfo.MetaInfo) (*TorrentSpec, error)

Jun 27, 2021

retracted

Changes in this version

+ var DefaultNetDialer = &net.Dialer

+ type AnacrolixDhtServerWrapper struct

+ func (me AnacrolixDhtServerWrapper) Announce(hash [20]byte, port int, impliedPort bool) (DhtAnnounce, error)

+ func (me AnacrolixDhtServerWrapper) Ping(addr *net.UDPAddr)

+ func (me AnacrolixDhtServerWrapper) Stats() interface{}

type Client

+ func (cl *Client) Listeners() []Listener

+ func (cl *Client) NewAnacrolixDhtServer(conn net.PacketConn) (s *dht.Server, err error)

type ClientConfig

+ AcceptPeerConnections bool

+ MaxUnverifiedBytes int64

+ PeriodicallyAnnounceTorrentsToDht bool

type ConnStats

+ BytesReadUsefulIntendedData Count

+ type DialContexter interface

+ DialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ type DialResult struct

+ Conn net.Conn

+ Dialer Dialer

+ func DialFirst(ctx context.Context, addr string, dialers []Dialer) (res DialResult)

type Dialer

+ DialerNetwork func() string

+ type NetworkDialer struct

+ Dialer DialContexter

+ Network string

+ func (me NetworkDialer) Dial(ctx context.Context, addr string) (_ net.Conn, err error)

+ func (me NetworkDialer) DialerNetwork() string

type Torrent

+ func (t *Torrent) AnnounceToDht(s DhtServer) (done <-chan struct{}, stop func(), err error)

May 4, 2021

Changes in this version

+ const UpnpDiscoverLogTag

Mar 24, 2021

Changes in this version

type ClientConfig

+ ConfigureAnacrolixDhtServer func(*dht.ServerConfig)

+ type PeerStorer interface

+ PeerStore func() peer_store.Interface

Feb 9, 2021

Changes in this version

+ var WebseedHttpClient = &http.Client

Jan 29, 2021

Changes in this version

type Callbacks

+ DeletedRequest []func(PeerRequestEvent)

+ NewPeer []func(*Peer)

+ PeerClosed []func(*Peer)

+ ReceivedRequested []func(PeerMessageEvent)

+ ReceivedUsefulData []func(ReceivedUsefulDataEvent)

+ SentRequest []func(PeerRequestEvent)

+ type ChunkSpec struct

+ Begin pp.Integer

+ Length pp.Integer

type Peer

+ Discovery PeerSource

+ Network string

+ PeerClientName string

+ PeerExtensionIDs map[pp.ExtensionName]pp.ExtensionNumber

+ PeerListenPort int

+ PeerMaxRequests int

+ PeerPrefersEncryption bool

+ RemoteAddr PeerRemoteAddr

+ func (p *Peer) TryAsPeerConn() (*PeerConn, bool)

+ type PeerMessageEvent struct

+ Message *pp.Message

+ Peer *Peer

+ type PeerRemoteAddr interface

+ String func() string

+ type PeerRequestEvent struct

+ Peer *Peer

+ type ReceivedUsefulDataEvent = PeerMessageEvent

+ type Request struct

+ Index pp.Integer

+ func (r Request) ToMsg(mt pp.MessageType) pp.Message

Jan 18, 2021

Changes in this version

type ClientConfig

+ DropMutuallyCompletePeers bool

Dec 17, 2020

Changes in this version

+ const PeerSourceDirect

type Callbacks

+ ReceiveEncryptedHandshakeSkeys mse.SecretKeyIter

type Client

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

type Listener

+ Accept func() (net.Conn, error)

+ Addr func() net.Addr

type PieceState

+ Hashing bool

+ Marking bool

+ QueuedForHash bool

type TorrentSpec

+ PeerAddrs []string

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

Oct 15, 2020

Changes in this version

type Callbacks

+ PeerConnClosed func(*PeerConn)

Oct 5, 2020

Changes in this version

type Client

+ func (cl *Client) ConnStats() ConnStats

type ClientConfig

+ TotalHalfOpenConns int

Sep 3, 2020

Changes in this version

+ type Callbacks struct

+ CompletedHandshake func(_ *PeerConn, infoHash InfoHash)

+ ReadExtendedHandshake func(*PeerConn, *pp.ExtendedHandshakeMessage)

+ ReadMessage func(*PeerConn, *pp.Message)

type ClientConfig

+ Callbacks Callbacks

+ DisableWebseeds bool

+ DisableWebtorrent bool

+ DropDuplicatePeerIds bool

+ Extensions PeerExtensionBits

+ type PeerInfo struct

+ Addr net.Addr

+ Id [20]byte

+ Source PeerSource

+ SupportsEncryption bool

+ Trusted bool

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

type Piece

+ func (p *Piece) UpdateCompletion()

type Torrent

+ func (t *Torrent) AllowDataUpload()

+ func (t *Torrent) DisallowDataUpload()

+ func (t *Torrent) MergeSpec(spec *TorrentSpec) error

type TorrentSpec

+ DhtNodes []string

+ DisallowDataDownload bool

+ DisallowDataUpload bool

+ Sources []string

+ Webseeds []string

Mar 24, 2020

Changes in this version

+ const PeerSourceDhtAnnouncePeer

+ const PeerSourceDhtGetPeers

+ const PeerSourceIncoming

+ const PeerSourcePex

+ const PeerSourceTracker

type Client

+ func (cl *Client) AddDhtServer(d DhtServer)

+ type DhtAnnounce interface

+ Close func()

+ Peers func() <-chan dht.PeersValues

+ type DhtServer interface

+ AddNode func(ni krpc.NodeInfo) error

+ Addr func() net.Addr

+ Announce func(hash [20]byte, port int, impliedPort bool) (DhtAnnounce, error)

+ ID func() [20]byte

+ Ping func(addr *net.UDPAddr)

+ Stats func() interface{}

+ WriteStatus func(io.Writer)

+ type PeerConn struct

+ Discovery PeerSource

+ PeerClientName string

+ PeerExtensionBytes pp.PeerExtensionBits

+ PeerExtensionIDs map[pp.ExtensionName]pp.ExtensionNumber

+ PeerID PeerID

+ PeerMaxRequests int

+ func (c *PeerConn) String() string

+ func (cn *PeerConn) PeerPieces() bitmap.Bitmap

+ type PeerSource string

type Piece

+ func (p *Piece) State() PieceState

type PieceStateRun

+ func (psr PieceStateRun) String() (ret string)

+ type PieceStateRuns []PieceStateRun

+ func (me PieceStateRuns) String() string

type Torrent

+ func (t *Torrent) AllowDataDownload()

+ func (t *Torrent) DisallowDataDownload()

+ func (t *Torrent) PeerConns() []*PeerConn

+ func (t *Torrent) SetOnWriteChunkError(f func(error))

Feb 20, 2020

Changes in this version

+ var TestingTempDir tmproot.Dir

type Client

+ func (cl *Client) AddDialer(d Dialer)

+ func (cl *Client) AddListener(l Listener)

type ClientConfig

+ func TestingConfig() *ClientConfig

+ type Dialer interface

+ Dial func(_ context.Context, addr string) (net.Conn, error)

+ LocalAddr func() net.Addr

+ type Listener interface

+ type NetDialer struct

+ Dialer net.Dialer

+ Network string

+ func (me NetDialer) Dial(ctx context.Context, addr string) (_ net.Conn, err error)

+ func (me NetDialer) LocalAddr() net.Addr

type Peer

+ Addr net.Addr

Jan 28, 2020

Changes in this version

+ type RequestStrategyMaker func(callbacks requestStrategyCallbacks, clientLocker sync.Locker) requestStrategy

+ func RequestStrategyDuplicateRequestTimeout(duplicateRequestTimeout time.Duration) RequestStrategyMaker

+ func RequestStrategyFastest() RequestStrategyMaker

+ func RequestStrategyFuzzing() RequestStrategyMaker

Jan 23, 2020

Changes in this version

type ClientConfig

+ DefaultRequestStrategy requestStrategyMaker

Jan 3, 2020

Changes in this version

type ClientConfig

+ UpnpID string

type Peer

+ Trusted bool

Dec 13, 2019

Changes in this version

type File

+ func (f *File) BytesCompleted() int64

Oct 3, 2019

Changes in this version

type Client

+ func (cl *Client) String() string

Aug 22, 2019

Changes in this version

type ClientConfig

+ Logger log.Logger

Jul 25, 2019

Changes in this version

type ClientConfig

+ CryptoProvides mse.CryptoMethod

+ CryptoSelector mse.CryptoSelector

+ HeaderObfuscationPolicy HeaderObfuscationPolicy

+ type HeaderObfuscationPolicy struct

+ Preferred bool

+ RequirePreferred bool

Jun 13, 2019

Changes in this version

type ClientConfig

+ DHTOnQuery func(query *krpc.Msg, source net.Addr) (propagate bool)

type Count

+ func (me *Count) MarshalJSON() ([]byte, error)

Jan 8, 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