Versions in this module Expand all Collapse all v0 v0.5.5 Jul 8, 2023 Changes in this version + var DefaultHandlerFunc = TaskHandlerFunc(OliveDefault) + var DefaultTaskMux = &defaultTaskMux + func OliveArchive(t *Task) error + func OliveBiliup(t *Task) error + func OliveDefault(t *Task) error + func OliveTrash(t *Task) error + type Task struct + Cmd *exec.Cmd + Filepath string + StopChan chan struct{} + type TaskGroup struct + Filepath string + PostCmds []*exec.Cmd + type TaskHandler interface + Process func(t *Task) error + type TaskHandlerFunc func(t *Task) error + func (f TaskHandlerFunc) Process(t *Task) error + type TaskMux struct + func (mux *TaskMux) MustGetHandler(pattern string) TaskHandler + func (mux *TaskMux) RegisterHandler(pattern string, handler TaskHandler) + type Uploader interface + func NewUploader(log *logrus.Logger, cfg *config.Config, taskGroup *TaskGroup) Uploader + type WorkerPool struct + var UploaderWorkerPool *WorkerPool + func NewWorkerPool(log *logrus.Logger, concurrency uint, cfg *config.Config) *WorkerPool + func (wp *WorkerPool) AddTask(tasks ...*TaskGroup) + func (wp *WorkerPool) BiliupPrerun() + func (wp *WorkerPool) Run() + func (wp *WorkerPool) Stop()