Versions in this module Expand all Collapse all v0 v0.52.1 Jan 19, 2026 v0.52.0 Jan 19, 2026 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 + ID string + IgnoreErrors bool + Progress ProgressTracker + func NewBatchImportTask(id string, ctx context.Context, elems []TaskElement, progress ProgressTracker, ...) *Task + func (t *Task) Count() int + func (t *Task) Execute(ctx context.Context) error + func (t *Task) FailedFiles() []string + func (t *Task) Processing() []TaskElementInfo + func (t *Task) TaskID() string + func (t *Task) Title() string + func (t *Task) TotalSize() int64 + func (t *Task) Type() tasktype.TaskType + func (t *Task) Uploaded() int64 + type TaskElement struct + FileInfo storagetypes.FileInfo + ID string + SourcePath string + SourceStorage storage.Storage + TargetChatID int64 + TargetStorage storage.Storage + func NewTaskElement(sourceStorage storage.Storage, fileInfo storagetypes.FileInfo, ...) *TaskElement + func (e *TaskElement) FileName() string + func (e *TaskElement) FileSize() int64 + func (e *TaskElement) GetSourcePath() string + func (e *TaskElement) SourceStorageName() string + type TaskElementInfo interface + FileName func() string + FileSize func() int64 + GetSourcePath func() string + SourceStorageName func() string + type TaskInfo interface + Count func() int + FailedFiles func() []string + Processing func() []TaskElementInfo + TaskID func() string + TotalSize func() int64 + Uploaded func() int64
Go to main page