batchtftask

Jun 20, 2025

Changes in this version

type Task

+ func (t *Task) Type() tasktype.TaskType

Jun 15, 2025

Changes in this version

+ type Progress struct

+ ChatID int64

+ MessageID int

+ func (p *Progress) OnDone(ctx context.Context, info TaskInfo, err error)

+ func (p *Progress) OnProgress(ctx context.Context, info TaskInfo)

+ func (p *Progress) OnStart(ctx context.Context, info TaskInfo)

+ type ProgressTracker interface

+ OnDone func(ctx context.Context, info TaskInfo, err error)

+ OnProgress func(ctx context.Context, info TaskInfo)

+ OnStart func(ctx context.Context, info TaskInfo)

+ func NewProgressTracker(messageID int, chatID int64) ProgressTracker

+ type Task struct

+ Ctx context.Context

+ Elems []TaskElement

+ ID string

+ IgnoreErrors bool

+ Progress ProgressTracker

+ func NewBatchTGFileTask(id string, ctx context.Context, files []TaskElement, client tdler.Client, ...) *Task

+ func (t *Task) Count() int

+ func (t *Task) Downloaded() int64

+ func (t *Task) Execute(ctx context.Context) error

+ func (t *Task) Processing() []TaskElementInfo

+ func (t *Task) TaskID() string

+ func (t *Task) TotalSize() int64

+ type TaskElement struct

+ File tfile.TGFile

+ ID string

+ Path string

+ Storage storage.Storage

+ func NewTaskElement(stor storage.Storage, path string, file tfile.TGFile) (*TaskElement, error)

+ func (e *TaskElement) FileName() string

+ func (e *TaskElement) FileSize() int64

+ func (e *TaskElement) StorageName() string

+ func (e *TaskElement) StoragePath() string

+ type TaskElementInfo interface

+ FileName func() string

+ FileSize func() int64

+ StorageName func() string

+ StoragePath func() string

+ type TaskInfo interface

+ Count func() int

+ Downloaded func() int64

+ Processing func() []TaskElementInfo

+ TaskID func() string

+ TotalSize func() int64