agent

type Orchestrator interface {
	Start() error
	Stop() error
	GetConfig() *gateway.Config
	TriggerRule(ruleName string) error
	GetRuleStatus(ruleName string) (*gateway.RuleStatus, bool)
	GetWatchedPaths() []string
	ReadFileContent(path string) ([]byte, error)
	SetGlobalDebounceDelay(duration time.Duration)
	SetVerbose(verbose bool)
}

type OrchestratorV2 struct {
	ConfigPath   string
	Config       *gateway.Config
	Verbose      bool
	Watcher      *fsnotify.Watcher
	LogManager   *utils.LogManager
	ColorManager *utils.ColorManager
	// contains filtered or unexported fields
}

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

type RuleRunner interface {
	// Lifecycle management
	Start() error   // Start monitoring and execution
	Stop() error    // Stop all processes and cleanup
	Restart() error // Restart all processes
	Execute() error // Execute the rule's commands

	// Status and state
	IsRunning() bool
	GetStatus() *gateway.RuleStatus
	GetRule() gateway.Rule

	// Debouncing
	TriggerDebounced() // Called when a file change is detected

	// Process management
	TerminateProcesses() error

	// Configuration
	SetDebounceDelay(duration time.Duration)
	SetVerbose(verbose bool)
}