aria2

Documentation

Index

• Constants
• Variables
• func AddURI(ctx context.Context, uri string, dstDirPath string) error
• func InitAria2Client(uri string, secret string, timeout int) (string, error)
• func InitClient(timeout int) (string, error)
• func IsAria2Ready() bool
• type Monitor
  • func (m *Monitor) Complete() error
  • func (m *Monitor) Loop() error
  • func (m *Monitor) Update() (bool, error)
• type Notify
  • func NewNotify() *Notify
  • func (n *Notify) OnBtDownloadComplete(events []rpc.Event)
  • func (n *Notify) OnDownloadComplete(events []rpc.Event)
  • func (n *Notify) OnDownloadError(events []rpc.Event)
  • func (n *Notify) OnDownloadPause(events []rpc.Event)
  • func (n *Notify) OnDownloadStart(events []rpc.Event)
  • func (n *Notify) OnDownloadStop(events []rpc.Event)

Constants

const (
	Downloading = iota
	Paused
	Stopped
	Completed
	Errored
)

Variables

var DownTaskManager = task.NewTaskManager[string](3)

var TransferTaskManager = task.NewTaskManager(3, func(k *uint64) {
	atomic.AddUint64(k, 1)
})

Functions

func AddURI

func AddURI(ctx context.Context, uri string, dstDirPath string) error

func InitAria2Client

func InitAria2Client(uri string, secret string, timeout int) (string, error)

func InitClient

func InitClient(timeout int) (string, error)

func IsAria2Ready

func IsAria2Ready() bool

Types

type Monitor

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

func (*Monitor) Complete

func (m *Monitor) Complete() error

func (*Monitor) Loop

func (m *Monitor) Loop() error

func (*Monitor) Update

func (m *Monitor) Update() (bool, error)

type Notify

type Notify struct {
	Signals generic_sync.MapOf[string, chan int]
}

func NewNotify

func NewNotify() *Notify

func (*Notify) OnBtDownloadComplete

func (n *Notify) OnBtDownloadComplete(events []rpc.Event)

func (*Notify) OnDownloadComplete

func (n *Notify) OnDownloadComplete(events []rpc.Event)

func (*Notify) OnDownloadError

func (n *Notify) OnDownloadError(events []rpc.Event)

func (*Notify) OnDownloadPause

func (n *Notify) OnDownloadPause(events []rpc.Event)

func (*Notify) OnDownloadStart

func (n *Notify) OnDownloadStart(events []rpc.Event)

func (*Notify) OnDownloadStop

func (n *Notify) OnDownloadStop(events []rpc.Event)