download

Dec 9, 2024

Changes in this version

type ExtensionTask

+ Meta *ExtensionTaskMeta

+ type ExtensionTaskMeta struct

+ Req *base.Request

Sep 21, 2024

Changes in this version

type Downloader

+ func (d *Downloader) ContinueBatch(filter *TaskFilter) (err error)

+ func (d *Downloader) GetTasksByFilter(filter *TaskFilter) []*Task

type DownloaderConfig

+ DownloadDirWhiteList []string

+ type TaskFilter struct

+ IDs []string

+ NotStatuses []base.Status

+ Statuses []base.Status

+ func (f *TaskFilter) IsEmpty() bool

Sep 7, 2024

Changes in this version

type ActivationEvent

+ const EventOnDone

type InstanceEvents

+ func (h InstanceEvents) OnDone(fn goja.Callable)

+ type OnDoneContext struct

+ Task *Task

type Task

+ func (t *Task) MarshalJSON() ([]byte, error)

+ func (t *Task) Name() string

Aug 9, 2024

Changes in this version

type DownloaderConfig

+ FetchManagers []fetcher.FetcherManager

type Progress

+ UploadSpeed int64

+ Uploaded int64

type Task

+ Uploading bool

May 17, 2024

Changes in this version

type Downloader

+ func (d *Downloader) CreateDirectBatch(reqs []*base.Request, opts *base.Options) (taskId []string, err error)

Jan 30, 2024

Changes in this version

+ var ErrUnSupportedProtocol = errors.New("unsupported protocol")

type Downloader

+ func (d *Downloader) DeleteByStatues(statues []base.Status, force bool) (err error)

+ func (d *Downloader) GetTasksByStatues(statues []base.Status) []*Task

+ func (d *Downloader) Stats(id string) (sr any, err error)

type Task

+ Protocol string

Dec 13, 2023

Changes in this version

type ActivationEvent

+ const EventOnError

+ type ExtensionTask struct

+ func NewExtensionTask(download *Downloader, task *Task) *ExtensionTask

+ func (t *ExtensionTask) Continue() error

+ func (t *ExtensionTask) Pause() error

type InstanceEvents

+ func (h InstanceEvents) OnError(fn goja.Callable)

+ type OnErrorContext struct

+ Error error

+ Task *ExtensionTask

type Task

+ UpdatedAt time.Time

Dec 2, 2023

Changes in this version

+ type DownloaderProxyConfig struct

+ Enable bool

+ Host string

+ Pwd string

+ Scheme string

+ Usr string

type DownloaderStoreConfig

+ Proxy *DownloaderProxyConfig

+ func (cfg *DownloaderStoreConfig) ProxyUrl() *url.URL

Oct 20, 2023

Changes in this version

type ActivationEvent

+ const EventOnStart

+ type ExtensionInfo struct

+ Author string

+ Identity string

+ Name string

+ Title string

+ Version string

+ func NewExtensionInfo(ext *Extension) *ExtensionInfo

type Instance

+ Info *ExtensionInfo

+ Settings map[string]any

+ Storage *ContextStorage

type InstanceEvents

+ func (h InstanceEvents) OnStart(fn goja.Callable)

+ type Match struct

+ Labels []string

+ Urls []string

+ type OnResolveContext struct

+ Req *base.Request

+ Res *base.Resource

+ type OnStartContext struct

+ Task *Task

type Script

+ Match *Match

Oct 18, 2023

Changes in this version

type Context

+ Storage *ContextStorage

+ type ContextStorage struct

+ func (s *ContextStorage) Clear()

+ func (s *ContextStorage) Get(key string) any

+ func (s *ContextStorage) Keys() []string

+ func (s *ContextStorage) Remove(key string)

+ func (s *ContextStorage) Set(key string, value string)

Oct 17, 2023

Changes in this version

+ var ErrExtensionNoManifest = fmt.Errorf("manifest.json not found")

+ var ErrExtensionNotFound = fmt.Errorf("extension not found")

+ var ErrTaskNotFound = errors.New("task not found")

+ type ActivationEvent string

+ const EventOnResolve

+ type Context struct

+ Req *base.Request

+ Res *base.Resource

+ Settings map[string]any

type Downloader

+ ExtensionLogger *logger.Logger

+ Logger *logger.Logger

+ func (d *Downloader) DeleteExtension(identity string) error

+ func (d *Downloader) ExtensionPath(ext *Extension) string

+ func (d *Downloader) GetExtension(identity string) (*Extension, error)

+ func (d *Downloader) GetExtensions() []*Extension

+ func (d *Downloader) InstallExtensionByFolder(path string, devMode bool) (*Extension, error)

+ func (d *Downloader) InstallExtensionByGit(url string) (*Extension, error)

+ func (d *Downloader) SwitchExtension(identity string, status bool) error

+ func (d *Downloader) UpdateExtensionSettings(identity string, settings map[string]any) error

+ func (d *Downloader) UpgradeCheckExtension(identity string) (newVersion string, err error)

+ func (d *Downloader) UpgradeExtension(identity string) error

type DownloaderConfig

+ ProductionMode bool

+ type Extension struct

+ Author string

+ CreatedAt time.Time

+ Description string

+ DevMode bool

+ DevPath string

+ Disabled bool

+ Homepage string

+ Icon string

+ Identity string

+ Name string

+ Repository *Repository

+ Scripts []*Script

+ Settings []*Setting

+ Title string

+ UpdatedAt time.Time

+ Version string

+ type Instance struct

+ Events InstanceEvents

+ Logger *InstanceLogger

+ type InstanceEvents map[ActivationEvent]goja.Callable

+ func (h InstanceEvents) OnResolve(fn goja.Callable)

+ type InstanceLogger struct

+ func (l *InstanceLogger) Debug(msg ...any)

+ func (l *InstanceLogger) Error(msg ...any)

+ func (l *InstanceLogger) Info(msg ...any)

+ func (l *InstanceLogger) Warn(msg ...any)

+ type Option struct

+ Label string

+ Value any

+ type Repository struct

+ Directory string

+ Url string

+ type Script struct

+ Entry string

+ Event string

+ Matches []string

+ type Setting struct

+ Description string

+ Name string

+ Options []*Option

+ Required bool

+ Title string

+ Type SettingType

+ Value any

+ type SettingType string

+ const SettingTypeBoolean

+ const SettingTypeNumber

+ const SettingTypeString

Jul 5, 2023

Changes in this version

type DownloaderConfig

+ StorageDir string

Jun 9, 2023

Changes in this version

type Downloader

+ func (d *Downloader) ContinueAll() (err error)

+ func (d *Downloader) PauseAll() (err error)

May 11, 2023

Changes in this version

type Downloader

+ func (d *Downloader) CreateDirect(req *base.Request, opts *base.Options) (taskId string, err error)

type DownloaderConfig

+ RefreshInterval int

type DownloaderStoreConfig

+ FirstLoad bool

+ MaxRunning int

+ func (cfg *DownloaderStoreConfig) Init() *DownloaderStoreConfig

Apr 1, 2023

Changes in this version

+ const EventKeyContinue

+ const EventKeyDelete

+ const EventKeyDone

+ const EventKeyError

+ const EventKeyFinally

+ const EventKeyPause

+ const EventKeyProgress

+ const EventKeyStart

+ func Boot() *boot

+ type BoltStorage struct

+ func NewBoltStorage(dir string) *BoltStorage

+ func (b *BoltStorage) Clear() error

+ func (b *BoltStorage) Close() error

+ func (b *BoltStorage) Delete(bucket string, key string) error

+ func (b *BoltStorage) Get(bucket string, key string, v any) (bool, error)

+ func (b *BoltStorage) List(bucket string, v any) error

+ func (b *BoltStorage) Pop(bucket string, key string, v any) error

+ func (b *BoltStorage) Put(bucket string, key string, v any) error

+ func (b *BoltStorage) Setup(buckets []string) error

+ type Downloader struct

+ func NewDownloader(cfg *DownloaderConfig) *Downloader

+ func (d *Downloader) Clear() error

+ func (d *Downloader) Close() error

+ func (d *Downloader) Continue(id string) (err error)

+ func (d *Downloader) Create(rrId string, opts *base.Options) (taskId string, err error)

+ func (d *Downloader) Delete(id string, force bool) (err error)

+ func (d *Downloader) DirectCreate(req *base.Request, opts *base.Options) (taskId string, err error)

+ func (d *Downloader) GetConfig() (bool, *DownloaderStoreConfig, error)

+ func (d *Downloader) GetTask(id string) *Task

+ func (d *Downloader) GetTasks() []*Task

+ func (d *Downloader) Listener(fn Listener)

+ func (d *Downloader) Pause(id string) (err error)

+ func (d *Downloader) PutConfig(v *DownloaderStoreConfig) error

+ func (d *Downloader) Resolve(req *base.Request) (rr *ResolveResult, err error)

+ func (d *Downloader) Setup() error

+ type DownloaderConfig struct

+ Controller *controller.Controller

+ FetchBuilders []fetcher.FetcherBuilder

+ Storage Storage

+ func (cfg *DownloaderConfig) Init() *DownloaderConfig

+ type DownloaderStoreConfig struct

+ DownloadDir string

+ Extra map[string]any

+ ProtocolConfig map[string]any

+ RefreshInterval int

+ type Event struct

+ Err error

+ Key EventKey

+ Task *Task

+ type EventKey string

+ type Listener func(event *Event)

+ type MemStorage struct

+ func NewMemStorage() *MemStorage

+ func (n *MemStorage) Clear() error

+ func (n *MemStorage) Close() error

+ func (n *MemStorage) Delete(bucket string, key string) error

+ func (n *MemStorage) Get(bucket string, key string, v any) (bool, error)

+ func (n *MemStorage) List(bucket string, v any) error

+ func (n *MemStorage) Pop(bucket string, key string, v any) error

+ func (n *MemStorage) Put(bucket string, key string, v any) error

+ func (n *MemStorage) Setup(buckets []string) error

+ type Progress struct

+ Downloaded int64

+ Speed int64

+ Used int64

+ type ResolveResult struct

+ ID string

+ Res *base.Resource

+ type Storage interface

+ Clear func() error

+ Close func() error

+ Delete func(bucket string, key string) error

+ Get func(bucket string, key string, v any) (bool, error)

+ List func(bucket string, v any) error

+ Pop func(bucket string, key string, v any) error

+ Put func(bucket string, key string, v any) error

+ Setup func(buckets []string) error

+ type Task struct

+ CreatedAt time.Time

+ ID string

+ Meta *fetcher.FetcherMeta

+ Progress *Progress

+ Size int64

+ Status base.Status

+ func NewTask() *Task