task

package
v1.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2025 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ShareInfo

type ShareInfo struct {
	PanType string
	ShareID string
	URL     string
}

ShareInfo 分享信息结构

type TaskManager

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

TaskManager 任务管理器

func NewTaskManager

func NewTaskManager(repoMgr *repo.RepositoryManager) *TaskManager

NewTaskManager 创建任务管理器

func (*TaskManager) GetTaskStatus

func (tm *TaskManager) GetTaskStatus(taskID uint) (string, error)

GetTaskStatus 获取任务状态

func (*TaskManager) IsTaskRunning

func (tm *TaskManager) IsTaskRunning(taskID uint) bool

IsTaskRunning 检查任务是否在运行

func (*TaskManager) PauseTask

func (tm *TaskManager) PauseTask(taskID uint) error

PauseTask 暂停任务

func (*TaskManager) RecoverRunningTasks

func (tm *TaskManager) RecoverRunningTasks() error

RecoverRunningTasks 恢复运行中的任务(服务器重启后调用)

func (*TaskManager) RegisterProcessor

func (tm *TaskManager) RegisterProcessor(processor TaskProcessor)

RegisterProcessor 注册任务处理器

func (*TaskManager) StartTask

func (tm *TaskManager) StartTask(taskID uint) error

StartTask 启动任务

func (*TaskManager) StopTask

func (tm *TaskManager) StopTask(taskID uint) error

StopTask 停止任务

type TaskProcessor

type TaskProcessor interface {
	Process(ctx context.Context, taskID uint, item *entity.TaskItem) error
	GetTaskType() string
}

TaskProcessor 任务处理器接口

type TransferInput

type TransferInput struct {
	Title      string `json:"title"`
	URL        string `json:"url"`
	CategoryID uint   `json:"category_id"`
	PanID      uint   `json:"pan_id"`
	Tags       []uint `json:"tags"`
}

TransferInput 转存任务输入数据结构

type TransferOutput

type TransferOutput struct {
	ResourceID uint   `json:"resource_id,omitempty"`
	SaveURL    string `json:"save_url,omitempty"`
	Error      string `json:"error,omitempty"`
	Success    bool   `json:"success"`
	Time       string `json:"time"`
}

TransferOutput 转存任务输出数据结构

type TransferProcessor

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

TransferProcessor 转存任务处理器

func NewTransferProcessor

func NewTransferProcessor(repoMgr *repo.RepositoryManager) *TransferProcessor

NewTransferProcessor 创建转存任务处理器

func (*TransferProcessor) GetTaskType

func (tp *TransferProcessor) GetTaskType() string

GetTaskType 获取任务类型

func (*TransferProcessor) Process

func (tp *TransferProcessor) Process(ctx context.Context, taskID uint, item *entity.TaskItem) error

Process 处理转存任务项

type TransferResult

type TransferResult struct {
	Success  bool   `json:"success"`
	SaveURL  string `json:"save_url"`
	ErrorMsg string `json:"error_msg"`
}

TransferResult 转存结果

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL