progress

Jan 7, 2026

Changes in this version

+ func ContextCallStack(ctx context.Context, jobName string, jobSize, stepID int) context.Context

+ func ContextForEach(ctx context.Context, jobName string, index, total int) context.Context

+ func ContextRouter(ctx context.Context, jobName string) context.Context

+ type ProgressBar interface

+ BatchComplete func()

+ BatchProgress func(processed, total int)

+ BatchStart func(inputPath, outputPath string, mutable bool)

+ ChunkingStart func(strategy string, chunkCount int)

+ DocumentComplete func(path string, duration time.Duration)

+ DocumentError func(path string, err error)

+ DocumentSkipped func(path string, reason string)

+ DocumentStart func(path string, sizeKB float64)

+ ForeachComplete func(successCount, totalCount int, duration time.Duration)

+ ForeachItem func(index, total int, status string)

+ ForeachStart func(itemCount int)

+ GetStats func() Stats

+ RetryAttempt func(attempt, maxAttempts int, delay time.Duration)

+ RetryExhausted func(maxAttempts int)

+ RetrySuccess func(attempt int)

+ RouterDefault func(targetJob string)

+ RouterEvaluating func()

+ RouterMatched func(routeName string, targetJob string)

+ RouterNoMatch func()

+ SetForeachMode func(inForeach bool)

+ SetTokenSource func(source TokenSource)

+ StepComplete func(jobName, stepName string, stepNum, totalSteps int, duration time.Duration, ...)

+ StepError func(jobName, stepName string, stepNum, totalSteps int, err error)

+ StepProgress func(message string)

+ StepSkipped func(jobName, stepName string, stepNum, totalSteps int, reason string)

+ StepStart func(jobName, stepName string, stepNum, totalSteps int)

+ Summary func()

+ SummaryQuick func(docCount int, duration time.Duration)

+ ThinkingContent func(text string)

+ UpdateTokens func(inputTokens, outputTokens int)

+ WorkflowCompiled func(name string, jobCount, stepCount int)

+ WorkflowError func(err error)

+ WorkflowLoading func(path string)

+ type Silent struct

+ func NewSilent() *Silent

+ func (s *Silent) BatchComplete()

+ func (s *Silent) BatchProgress(processed, total int)

+ func (s *Silent) BatchStart(inputPath, outputPath string, mutable bool)

+ func (s *Silent) ChunkingStart(strategy string, chunkCount int)

+ func (s *Silent) DocumentComplete(path string, duration time.Duration)

+ func (s *Silent) DocumentError(path string, err error)

+ func (s *Silent) DocumentSkipped(path string, reason string)

+ func (s *Silent) DocumentStart(path string, sizeKB float64)

+ func (s *Silent) ForeachComplete(successCount, totalCount int, duration time.Duration)

+ func (s *Silent) ForeachItem(index, total int, status string)

+ func (s *Silent) ForeachStart(itemCount int)

+ func (s *Silent) GetStats() Stats

+ func (s *Silent) RetryAttempt(attempt, maxAttempts int, delay time.Duration)

+ func (s *Silent) RetryExhausted(maxAttempts int)

+ func (s *Silent) RetrySuccess(attempt int)

+ func (s *Silent) RouterDefault(targetJob string)

+ func (s *Silent) RouterEvaluating()

+ func (s *Silent) RouterMatched(routeName string, targetJob string)

+ func (s *Silent) RouterNoMatch()

+ func (s *Silent) SetForeachMode(inForeach bool)

+ func (s *Silent) SetTokenSource(source TokenSource)

+ func (s *Silent) StepComplete(jobName, stepName string, stepNum, totalSteps int, duration time.Duration, ...)

+ func (s *Silent) StepError(jobName, stepName string, stepNum, totalSteps int, err error)

+ func (s *Silent) StepProgress(message string)

+ func (s *Silent) StepSkipped(jobName, stepName string, stepNum, totalSteps int, reason string)

+ func (s *Silent) StepStart(jobName, stepName string, stepNum, totalSteps int)

+ func (s *Silent) Summary()

+ func (s *Silent) SummaryQuick(docCount int, duration time.Duration)

+ func (s *Silent) ThinkingContent(text string)

+ func (s *Silent) UpdateTokens(inputTokens, outputTokens int)

+ func (s *Silent) WorkflowCompiled(name string, jobCount, stepCount int)

+ func (s *Silent) WorkflowError(err error)

+ func (s *Silent) WorkflowLoading(path string)

type StepInfo

+ Attempt int

+ Delay int

+ ItemIndex int

+ ItemTotal int

+ JobSize int

+ Parent *StepInfo

+ StepID int

Jan 4, 2026

Changes in this version

type Reporter

+ func (r *Reporter) StepSkipped(jobName, stepName string, stepNum, totalSteps int, reason string)

Nov 13, 2025

Changes in this version

+ const IconBatchProcessing

+ const IconChunking

+ const IconDocumentComplete

+ const IconDocumentError

+ const IconDocumentSkipped

+ const IconDocumentStart

+ const IconForeachItem

+ const IconForeachStart

+ const IconRetryAttempt

+ const IconRetryExhausted

+ const IconRetrySuccess

+ const IconRouterEvaluating

+ const IconRouterMatched

+ const IconStepComplete

+ const IconStepError

+ const IconStepProcessing

+ const IconSummary

+ const IconThinking

+ const IconWarning

+ const IconWorkflowCompiled

+ const IconWorkflowError

+ const IconWorkflowLoad

+ func IsInForeachMode(ctx context.Context) bool

+ func WithForeachMode(ctx context.Context) context.Context

+ func WithReporter(ctx context.Context, reporter *Reporter) context.Context

+ func WithStepInfo(ctx context.Context, info StepInfo) context.Context

+ type ProfileTokenUsage struct

+ Name string

+ Usage TokenUsage

+ type Reporter struct

+ func FromContext(ctx context.Context) *Reporter

+ func New(quiet bool) *Reporter

+ func NewWithWriter(w io.Writer, quiet bool) *Reporter

+ func (r *Reporter) BatchComplete()

+ func (r *Reporter) BatchProgress(processed, total int)

+ func (r *Reporter) BatchStart(inputPath, outputPath string, mutable bool)

+ func (r *Reporter) ChunkingStart(strategy string, chunkCount int)

+ func (r *Reporter) DocumentComplete(path string, duration time.Duration)

+ func (r *Reporter) DocumentError(path string, err error)

+ func (r *Reporter) DocumentSkipped(path string, reason string)

+ func (r *Reporter) DocumentStart(path string, sizeKB float64)

+ func (r *Reporter) ForeachComplete(successCount, totalCount int, duration time.Duration)

+ func (r *Reporter) ForeachItem(index, total int, status string)

+ func (r *Reporter) ForeachStart(itemCount int)

+ func (r *Reporter) GetStats() Stats

+ func (r *Reporter) RetryAttempt(attempt, maxAttempts int, delay time.Duration)

+ func (r *Reporter) RetryExhausted(maxAttempts int)

+ func (r *Reporter) RetrySuccess(attempt int)

+ func (r *Reporter) RouterDefault(targetJob string)

+ func (r *Reporter) RouterEvaluating()

+ func (r *Reporter) RouterMatched(routeName string, targetJob string)

+ func (r *Reporter) RouterNoMatch()

+ func (r *Reporter) SetForeachMode(inForeach bool)

+ func (r *Reporter) SetTokenSource(source TokenSource)

+ func (r *Reporter) StepComplete(jobName, stepName string, stepNum, totalSteps int, duration time.Duration, ...)

+ func (r *Reporter) StepError(jobName, stepName string, stepNum, totalSteps int, err error)

+ func (r *Reporter) StepProgress(message string)

+ func (r *Reporter) StepStart(jobName, stepName string, stepNum, totalSteps int)

+ func (r *Reporter) Summary()

+ func (r *Reporter) SummaryQuick(docCount int, duration time.Duration)

+ func (r *Reporter) ThinkingContent(text string)

+ func (r *Reporter) UpdateTokens(inputTokens, outputTokens int)

+ func (r *Reporter) WorkflowCompiled(name string, jobCount, stepCount int)

+ func (r *Reporter) WorkflowError(err error)

+ func (r *Reporter) WorkflowLoading(path string)

+ type Stats struct

+ DocsErrors int

+ DocsProcessed int

+ DocsSkipped int

+ Errors []error

+ TokensInput int

+ TokensOutput int

+ type StepInfo struct

+ JobName string

+ StepName string

+ StepNum int

+ TotalSteps int

+ func GetStepInfo(ctx context.Context) *StepInfo

+ type TokenSource interface

+ ProfileUsage func() []ProfileTokenUsage

+ Usage func() TokenUsage

+ type TokenUsage struct

+ InputTokens int

+ ReplyTokens int