queue

package

v1.0.12 Latest Latest Go to latest Published: Jul 2, 2025 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func ForceAddDownloadQueue(channelId int64, model repository.Download) error

func GetDownloading() ([]repository.DownloadTask, error)

func MigrateDownloadTaskInfo(tasks []repository.DownloadTask)

func RemoveTasks(ids ...uint)

func ScanAndCreateNewDownloadTasks(processBefore *int64, channelId ...int64) (int, error)

func TryActivateTaskControl()

func UpdatePriority(id uint, priority int32)

type DownloadTask struct {
	ID uint

	ChannelID int64
	MsgID     int64
	// contains filtered or unexported fields
}

func NewTask(channelId int64, model repository.Download) (*DownloadTask, error)

func (task *DownloadTask) CompleteDownload() (ok bool, err error)

func (task *DownloadTask) GetVideoFile() (bool, error)

func (task *DownloadTask) Terminate() error

func (task *DownloadTask) UpdateOrDownload(forceStart bool) error

type TaskErrorState struct {
	Err string
	At  time.Time
}

type TaskFileState struct {
	File      *client.File
	UpdatedAt time.Time
}

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

func NewTaskLogger(id uint, logger log.FieldLogger) TaskLogger

func (tl TaskLogger) Errorln(args ...interface{})

func (tl TaskLogger) FatalNow()

func (tl TaskLogger) WithField(key string, value interface{}) TaskLogger