Versions in this module Expand all Collapse all v0 v0.4.0 Nov 3, 2026 Changes in this version + type Broadcaster interface + UpdateProgress func(queueID int, percentage int) + UpdateProgressWithStage func(queueID int, percentage int, stage string) + type ProgressBroadcaster struct + func NewProgressBroadcaster() *ProgressBroadcaster + func (pb *ProgressBroadcaster) BroadcastHealthChanged() + func (pb *ProgressBroadcaster) BroadcastQueueChanged() + func (pb *ProgressBroadcaster) ClearProgress(queueID int) + func (pb *ProgressBroadcaster) Close() error + func (pb *ProgressBroadcaster) CreateTracker(queueID, minPercent, maxPercent int) *Tracker + func (pb *ProgressBroadcaster) GetAllProgress() map[int]ProgressEntry + func (pb *ProgressBroadcaster) GetProgress(queueID int) (int, bool) + func (pb *ProgressBroadcaster) HasSubscribers() bool + func (pb *ProgressBroadcaster) NotifyComplete(queueID int, status string) + func (pb *ProgressBroadcaster) NotifyStreamable(queueID int, storagePath string) + func (pb *ProgressBroadcaster) Subscribe() (string, <-chan ProgressUpdate) + func (pb *ProgressBroadcaster) Unsubscribe(subID string) + func (pb *ProgressBroadcaster) UpdateProgress(queueID int, percentage int) + func (pb *ProgressBroadcaster) UpdateProgressWithStage(queueID int, percentage int, stage string) + type ProgressEntry struct + Percentage int + Stage string + type ProgressTracker interface + Update func(current, total int) + UpdateAbsolute func(percentage int) + type ProgressUpdate struct + Percentage int + QueueID int + Stage string + Status string + StoragePath string + Timestamp time.Time + type Tracker struct + func NewTracker(broadcaster Broadcaster, queueID, minPercent, maxPercent int) *Tracker + func (pt *Tracker) Slice(idx, count int) *Tracker + func (pt *Tracker) Update(current, total int) + func (pt *Tracker) UpdateAbsolute(percentage int) + func (pt *Tracker) WithStage(stage string) *Tracker
Go to main page