bt

Documentation

Index

• func CreateNativeZeroLengthFile(name string) error
• type DnsCacheResolver
  • func (r *DnsCacheResolver) DialContext(ctx context.Context, network, address string) (net.Conn, error)
  • func (r *DnsCacheResolver) Run(ctx context.Context)
• type Fetcher
  • func (f *Fetcher) Close() (err error)
  • func (f *Fetcher) Create(opts *base.Options) (err error)
  • func (f *Fetcher) Meta() *fetcher.FetcherMeta
  • func (f *Fetcher) Pause() (err error)
  • func (f *Fetcher) Progress() fetcher.Progress
  • func (f *Fetcher) Resolve(req *base.Request) error
  • func (f *Fetcher) Setup(ctl *controller.Controller)
  • func (f *Fetcher) Start() (err error)
  • func (f *Fetcher) Stats() any
  • func (f *Fetcher) Upload() (err error)
  • func (f *Fetcher) UploadedBytes() int64
  • func (f *Fetcher) Wait() (err error)
  • func (f *Fetcher) WaitUpload() (err error)
• type FetcherManager
  • func (fm *FetcherManager) AutoRename() bool
  • func (fm *FetcherManager) Build() fetcher.Fetcher
  • func (fm *FetcherManager) Close() error
  • func (fm *FetcherManager) DefaultConfig() any
  • func (fm *FetcherManager) Filters() []*fetcher.SchemeFilter
  • func (fm *FetcherManager) Name() string
  • func (fm *FetcherManager) ParseName(u string) string
  • func (fm *FetcherManager) Restore() (v any, f func(meta *fetcher.FetcherMeta, v any) fetcher.Fetcher)
  • func (fm *FetcherManager) Store(f fetcher.Fetcher) (data any, err error)

Functions

func CreateNativeZeroLengthFile

func CreateNativeZeroLengthFile(name string) error

A helper to create zero-length files which won't appear for file-orientated storage since no writes will ever occur to them (no torrent data is associated with a zero-length file). The caller should make sure the file name provided is safe/sanitized.

Types

type DnsCacheResolver

type DnsCacheResolver struct {
	RefreshTimeout time.Duration
	// contains filtered or unexported fields
}

DnsCacheResolver resolves DNS requests for an HTTP client using an in-memory cache.

func (*DnsCacheResolver) DialContext

func (r *DnsCacheResolver) DialContext(ctx context.Context, network, address string) (net.Conn, error)

func (*DnsCacheResolver) Run

func (r *DnsCacheResolver) Run(ctx context.Context)

type Fetcher

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

func (*Fetcher) Close

func (f *Fetcher) Close() (err error)

func (*Fetcher) Create

func (f *Fetcher) Create(opts *base.Options) (err error)

func (*Fetcher) Meta

func (f *Fetcher) Meta() *fetcher.FetcherMeta

func (*Fetcher) Pause

func (f *Fetcher) Pause() (err error)

func (*Fetcher) Progress

func (f *Fetcher) Progress() fetcher.Progress

func (*Fetcher) Resolve

func (f *Fetcher) Resolve(req *base.Request) error

func (*Fetcher) Setup

func (f *Fetcher) Setup(ctl *controller.Controller)

func (*Fetcher) Start

func (f *Fetcher) Start() (err error)

func (*Fetcher) Stats

func (f *Fetcher) Stats() any

func (*Fetcher) Upload

func (f *Fetcher) Upload() (err error)

func (*Fetcher) UploadedBytes

func (f *Fetcher) UploadedBytes() int64

func (*Fetcher) Wait

func (f *Fetcher) Wait() (err error)

func (*Fetcher) WaitUpload

func (f *Fetcher) WaitUpload() (err error)

type FetcherManager

type FetcherManager struct {
}

func (*FetcherManager) AutoRename

func (fm *FetcherManager) AutoRename() bool

func (*FetcherManager) Build

func (fm *FetcherManager) Build() fetcher.Fetcher

func (*FetcherManager) Close

func (fm *FetcherManager) Close() error

func (*FetcherManager) DefaultConfig

func (fm *FetcherManager) DefaultConfig() any

func (*FetcherManager) Filters

func (fm *FetcherManager) Filters() []*fetcher.SchemeFilter

func (*FetcherManager) Name

func (fm *FetcherManager) Name() string

func (*FetcherManager) ParseName

func (fm *FetcherManager) ParseName(u string) string

func (*FetcherManager) Restore

func (fm *FetcherManager) Restore() (v any, f func(meta *fetcher.FetcherMeta, v any) fetcher.Fetcher)

func (*FetcherManager) Store

func (fm *FetcherManager) Store(f fetcher.Fetcher) (data any, err error)