processor

type DSLConfig struct {
	Steps         []Step
	ParallelSteps map[string][]Step // Steps that can be executed in parallel
}

type NormalizeOptions struct {
	AllowEmpty bool // Whether to allow empty strings in the result
}

type PerformanceMetrics struct {
	InputProcessingTime  int64 // Time in milliseconds to process inputs
	ModelProcessingTime  int64 // Time in milliseconds for model processing
	ActionProcessingTime int64 // Time in milliseconds for action processing
	OutputProcessingTime int64 // Time in milliseconds for output processing
	TotalProcessingTime  int64 // Total time in milliseconds for the step
}

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

type ProgressType int

type ProgressUpdate struct {
	Type               ProgressType
	Message            string
	Error              error
	Step               *StepInfo           // Optional step information
	Stdout             string              // Content from STDOUT when Type is ProgressOutput
	IsParallel         bool                // Whether this update is from a parallel step
	ParallelID         string              // Identifier for the parallel step group
	PerformanceMetrics *PerformanceMetrics // Performance metrics for the step
}

type ProgressWriter interface {
	WriteProgress(update ProgressUpdate) error
}

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

type Step struct {
	Name   string
	Config StepConfig
}

type StepConfig struct {
	Input      interface{} `yaml:"input"`       // Can be string or map[string]interface{}
	Model      interface{} `yaml:"model"`       // Can be string or []string
	Action     interface{} `yaml:"action"`      // Can be string or []string
	Output     interface{} `yaml:"output"`      // Can be string or []string
	NextAction interface{} `yaml:"next-action"` // Can be string or []string
}

type StepDependency struct {
	Name      string
	DependsOn []string
}

type StepInfo struct {
	Name   string
	Model  string
	Action string
}