concurrent

type ConcurrentProcessor struct {
	// contains filtered or unexported fields
}

type ProcessorConfig struct {
	// MaxWorkers defines the maximum number of concurrent workers
	// If 0, uses number of CPU cores
	MaxWorkers int

	// Timeout for processing a single workflow file
	WorkflowTimeout time.Duration

	// Timeout for the entire analysis operation
	TotalTimeout time.Duration

	// Enable progress reporting
	ShowProgress bool

	// Buffer size for worker channels
	BufferSize int
}

type ProgressReporter struct {
	Total     int
	Completed int
	// contains filtered or unexported fields
}

type WorkflowJob struct {
	Workflow      parser.WorkflowFile
	StandardRules []rules.Rule
	PolicyEngine  *policies.PolicyEngine
	Config        *config.Config
}

type WorkflowResult struct {
	WorkflowName string
	Findings     []rules.Finding
	Error        error
	Duration     time.Duration
}