downloader

Documentation

Index

• type Config
• type DownloadFileRequest
• type Downloader
  • func New(conf *Config) *Downloader
  • func (d *Downloader) Download(ctx context.Context, n *nzb.Nzb) error
• type FileWorker
  • func (w *FileWorker) WriteAt(p []byte, off int64) (n int, err error)
• type Job
• type Queue
  • func (q *Queue) Add(j *Job)
  • func (q *Queue) Get() *Job
  • func (q *Queue) Len() int

Types

type Config

type Config struct {
	Servers []nntp.Config `yaml:"servers"`
}

type DownloadFileRequest

type DownloadFileRequest struct {
	Info   *nzb.File
	Folder string
	// contains filtered or unexported fields
}

type Downloader

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

func New

func New(conf *Config) *Downloader

func (*Downloader) Download

func (d *Downloader) Download(ctx context.Context, n *nzb.Nzb) error

type FileWorker

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

func (*FileWorker) WriteAt

func (w *FileWorker) WriteAt(p []byte, off int64) (n int, err error)

WriteAt implements io.WriterAt.

type Job

type Job struct {
	Name string
	// Ctx     context.Context
	Groups  []string
	Segment *nzb.Segment
	Decode  decoder.Decoder
	Buff    []byte

	OnDone func(error)
	// contains filtered or unexported fields
}

type Queue

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

func (*Queue) Add

func (q *Queue) Add(j *Job)

func (*Queue) Get

func (q *Queue) Get() *Job

func (*Queue) Len

func (q *Queue) Len() int