archiver

Documentation

Index

• Variables
• type Archiver
  • func NewArchiver(datadir string, concurrency int, logger *zap.SugaredLogger) *Archiver
  • func (a *Archiver) ActiveJobs() []string
  • func (a *Archiver) Add(id string, source string)
  • func (a *Archiver) Concurrency() int
  • func (a *Archiver) InProgress(id string) bool
  • func (a *Archiver) QueuedJobs() []string
  • func (a *Archiver) Remove(id string)
  • func (a *Archiver) SetConcurrency(n int)
• type Job

Variables

var (
	HTTPUserAgent = "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/55.0.2883.87 Safari/537.36"
)

Types

type Archiver

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

func NewArchiver

func NewArchiver(datadir string, concurrency int, logger *zap.SugaredLogger) *Archiver

func (*Archiver) ActiveJobs

func (a *Archiver) ActiveJobs() []string

func (*Archiver) Add

func (a *Archiver) Add(id string, source string)

func (*Archiver) Concurrency

func (a *Archiver) Concurrency() int

func (*Archiver) InProgress

func (a *Archiver) InProgress(id string) bool

func (*Archiver) QueuedJobs

func (a *Archiver) QueuedJobs() []string

func (*Archiver) Remove

func (a *Archiver) Remove(id string)

func (*Archiver) SetConcurrency

func (a *Archiver) SetConcurrency(n int)

type Job

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