task

Nov 28, 2025

Changes in this version

+ type GoogleIndexProcessor struct

+ func NewGoogleIndexProcessor(repoMgr *repo.RepositoryManager) *GoogleIndexProcessor

+ func (gip *GoogleIndexProcessor) BatchProcessURLs(ctx context.Context, urls []string, operation string, taskID uint) error

+ func (gip *GoogleIndexProcessor) GetTaskType() string

+ func (gip *GoogleIndexProcessor) Process(ctx context.Context, taskID uint, item *entity.TaskItem) error

+ func (gip *GoogleIndexProcessor) SubmitSitemap(ctx context.Context, sitemapURL string, taskID uint) error

+ type GoogleIndexProcessorConfig struct

+ Concurrency int

+ CredentialsFile string

+ RetryAttempts int

+ RetryDelay time.Duration

+ SiteURL string

+ TokenFile string

+ type GoogleIndexTaskInput struct

+ Operation string

+ SitemapURL string

+ URLs []string

+ type GoogleIndexTaskOutput struct

+ Error string

+ IndexStatus string

+ Message string

+ Result *google.URLInspectionResult

+ Success bool

+ Time string

+ URL string

type TaskManager

+ func (tm *TaskManager) CreateTask(taskType, name, description string, configID *uint) (*entity.Task, error)

+ func (tm *TaskManager) CreateTaskItems(taskID uint, items []*entity.TaskItem) error

+ func (tm *TaskManager) GetTask(taskID uint) (*entity.Task, error)

+ func (tm *TaskManager) GetTaskItemStats(taskID uint) (map[string]int, error)

+ func (tm *TaskManager) QueryTaskItems(taskID uint, page, pageSize int, status string) ([]*entity.TaskItem, int64, error)

Sep 28, 2025

Changes in this version

+ type ExpansionInput struct

+ DataSource map[string]interface{}

+ PanAccountID uint

+ type ExpansionOutput struct

+ Error string

+ Message string

+ Success bool

+ Time string

+ TransferredResources []TransferredResource

+ type ExpansionProcessor struct

+ func NewExpansionProcessor(repoMgr *repo.RepositoryManager) *ExpansionProcessor

+ func (ep *ExpansionProcessor) GetTaskType() string

+ func (ep *ExpansionProcessor) Process(ctx context.Context, taskID uint, item *entity.TaskItem) error

type TransferResult

+ Fid string

+ type TransferredResource struct

+ Title string

+ URL string

Aug 12, 2025

Changes in this version

+ type ShareInfo struct

+ PanType string

+ ShareID string

+ URL string

+ type TaskManager struct

+ func NewTaskManager(repoMgr *repo.RepositoryManager) *TaskManager

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

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

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

+ func (tm *TaskManager) RecoverRunningTasks() error

+ func (tm *TaskManager) RegisterProcessor(processor TaskProcessor)

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

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

+ type TaskProcessor interface

+ GetTaskType func() string

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

+ type TransferInput struct

+ CategoryID uint

+ PanID uint

+ Tags []uint

+ Title string

+ URL string

+ type TransferOutput struct

+ Error string

+ ResourceID uint

+ SaveURL string

+ Success bool

+ Time string

+ type TransferProcessor struct

+ func NewTransferProcessor(repoMgr *repo.RepositoryManager) *TransferProcessor

+ func (tp *TransferProcessor) GetTaskType() string

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

+ type TransferResult struct

+ ErrorMsg string

+ SaveURL string

+ Success bool