worker

type Job struct {
	InputPath  string
	OutputPath string
}

type JobExecutionTime struct {
	FilePath string
	Duration time.Duration
}

type Metrics struct {
	FilesProcessed       int       `json:"files_processed"`
	DirectoriesProcessed int       `json:"directories_processed"`
	ErrorsEncountered    int       `json:"errors_encountered"`
	SkippedFiles         int       `json:"skipped_files"`
	StartTime            time.Time `json:"start_time"`
	ElapsedTime          string    `json:"elapsed_time"`
	// contains filtered or unexported fields
}

type ProcessingError struct {
	Source   string   `json:"source"`         // Source file path
	Dest     string   `json:"dest,omitempty"` // Expected output file path (if applicable)
	Message  string   `json:"message,omitempty"`
	Reason   string   `json:"reason,omitempty"`    // Why it was skipped
	SkipType SkipType `json:"skip_type,omitempty"` // Type of skip reason
}

type SkipType string

type SkippedFile struct {
	Source    string   // Path to the source file
	Dest      string   // Expected output file path (if applicable)
	InputDir  string   // Root input directory
	OutputDir string   // Root output directory
	Reason    string   // Why the file was skipped
	SkipType  SkipType // Type of skip reason
}

type SummaryFormat string

type SummaryOptions struct {
	Format     SummaryFormat // Output format: text, json, none
	ReportFile string        // File path to export JSON summary
	IsVerbose  bool
}

type WorkerPoolManager struct {
	JobChan        chan Job
	ErrorsChan     chan ProcessingError
	SkippedChan    chan ProcessingError
	Metrics        *Metrics
	Factory        processor.ProcessorFactoryInterface
	InputDir       string
	OutputDir      string
	MarkerName     string
	ExecutionTimes []JobExecutionTime
	// contains filtered or unexported fields
}

type WorkerPoolOptions struct {
	Context              context.Context
	InputDir             string
	OutputDir            string
	ExcludeDir           string
	MarkerName           string
	NumWorkers           int
	IsProduction         bool // If `--prod` is set, process everything
	IsForce              bool // If `--force` is set, process everything
	IsTrackExecutionTime bool
}