progress

Jun 3, 2025

Changes in this version

+ func UpdateCtx(ctx context.Context, d Delta)

+ type Delta struct

+ Completed int

+ Failed int

+ Pending int

+ Running int

+ Skipped int

+ Total int

+ type Progress struct

+ CompletedTasks int

+ FailedTasks int

+ PendingTasks int

+ RootProcessID string

+ RunningTasks int

+ SkippedTasks int

+ StartedAt time.Time

+ TotalTasks int

+ Workflow string

+ func FromContext(ctx context.Context) (*Progress, bool)

+ func GetSnapshot(ctx context.Context) (Progress, bool)

+ func WithNewTracker(ctx context.Context, rootProcessID, workflow string, onChange func(Progress)) (context.Context, *Progress)

+ func (p *Progress) OnChange(cb func(Progress))

+ func (p *Progress) Snapshot() Progress

+ func (p *Progress) Update(d Delta)