agent

Aug 30, 2025

Changes in this version

type RuleRunner

+ func (r *RuleRunner) TriggerManual()

type Watcher

+ func (w *Watcher) EventChan() chan string

Aug 25, 2025

Changes in this version

+ type CorrelationTracker struct

+ func NewCorrelationTracker(verbose bool) *CorrelationTracker

+ func (ct *CorrelationTracker) GetCorrelationSummary() map[string]interface{}

+ func (ct *CorrelationTracker) RecordRuleEnd(ruleName string)

+ func (ct *CorrelationTracker) RecordRuleStart(ruleName, triggerType string)

+ func (ct *CorrelationTracker) RecordRuleTrigger(ruleName, triggerType, triggeringFile string)

+ type CycleDetectionConfig struct

+ DynamicProtection bool

+ Enabled bool

+ FileThrashThreshold int

+ FileThrashWindow int

+ MaxChainDepth int

+ MaxTriggersPerMinute int

type Orchestrator

+ func (o *Orchestrator) GetExecutionCount(ruleName string, duration time.Duration) int

+ func (o *Orchestrator) RecordExecution(ruleName string)

+ type RuleExecution struct

+ EndTime time.Time

+ RuleName string

+ StartTime time.Time

+ TriggerType string

type RuleJob

+ StartTime time.Time

+ func (j *RuleJob) CanBeKilled(newJob *RuleJob, orchestrator *Orchestrator) bool

+ func (j *RuleJob) IsManualTrigger() bool

type RuleRunner

+ func (r *RuleRunner) GetBackoffLevel() int

+ type RuleTrigger struct

+ RuleName string

+ TriggerTime time.Time

+ TriggerType string

+ TriggeringFile string

type TestConfig

+ CycleDetection *CycleDetectionConfig

type TestHelper

+ func (th *TestHelper) AssertRunningJobCount(workerPool *WorkerPool, expectedCount int)

type TestRule

+ Patterns []string

Aug 20, 2025

Changes in this version

+ type DefaultScheduler struct

+ func NewDefaultScheduler(orchestrator *Orchestrator, workerPool *WorkerPool, lroManager *LROManager) *DefaultScheduler

+ func (s *DefaultScheduler) ScheduleRule(event *TriggerEvent) error

+ func (s *DefaultScheduler) Start() error

+ func (s *DefaultScheduler) Stop() error

+ type LROManager struct

+ func NewLROManager(orchestrator *Orchestrator) *LROManager

+ func (lro *LROManager) GetRunningProcesses() map[string]int

+ func (lro *LROManager) IsProcessRunning(ruleName string) bool

+ func (lro *LROManager) RestartProcess(rule *pb.Rule, triggerType string) error

+ func (lro *LROManager) Stop() error

+ type LROProcess struct

type Orchestrator

+ func (o *Orchestrator) GetRuleRunner(ruleName string) *RuleRunner

+ type ProcessInfo struct

+ type ProcessManager struct

+ func NewProcessManager(verbose bool) *ProcessManager

+ func (pm *ProcessManager) GetProcessInfo(cmd *exec.Cmd, ruleName string) *ProcessInfo

+ func (pm *ProcessManager) TerminateProcess(processInfo *ProcessInfo) error

type RuleRunner

+ func (r *RuleRunner) UpdateStatus(isRunning bool, buildStatus string)

+ type Scheduler interface

+ ScheduleRule func(event *TriggerEvent) error

+ Start func() error

+ Stop func() error

+ type TestConfig struct

+ ProjectID string

+ Rules []TestRule

+ Settings map[string]interface{}

+ Verbose bool

+ func NewTestConfig(projectID string) *TestConfig

+ func (tc *TestConfig) AddLRORule(name string, commands []string) *TestConfig

+ func (tc *TestConfig) AddRule(rule TestRule) *TestConfig

+ func (tc *TestConfig) AddShortRunningRule(name string, commands []string) *TestConfig

+ func (tc *TestConfig) ToYAML() string

+ func (tc *TestConfig) WithMaxWorkers(max int) *TestConfig

+ type TestHelper struct

+ func NewTestHelper(t *testing.T, timeout time.Duration) *TestHelper

+ func (th *TestHelper) AssertLROProcessCount(lroManager *LROManager, expectedCount int)

+ func (th *TestHelper) AssertRuleStatus(orchestrator *Orchestrator, ruleName string, expectedRunning bool, ...)

+ func (th *TestHelper) WithOrchestrator(config *TestConfig, testFunc func(*TestOrchestrator))

+ func (th *TestHelper) WithRunningOrchestrator(config *TestConfig, testFunc func(*TestOrchestrator))

+ type TestOrchestrator struct

+ func (to *TestOrchestrator) CreateRule(name string, lro bool, commands []string)

+ func (to *TestOrchestrator) Stop()

+ func (to *TestOrchestrator) TriggerRule(ruleName string) error

+ func (to *TestOrchestrator) WaitForRuleCompletion(ruleName string, timeout time.Duration) error

+ type TestRule struct

+ Commands []string

+ Env map[string]string

+ ExcludePatterns []string

+ LRO bool

+ Name string

+ SkipRunOnInit bool

+ WatchPatterns []string

+ type TriggerEvent struct

+ Context context.Context

+ Rule *pb.Rule

+ TriggerType string

Aug 20, 2025

Changes in this version

+ type RuleJob struct

+ Context context.Context

+ CreatedAt time.Time

+ JobID string

+ Rule *pb.Rule

+ TriggerType string

+ func NewRuleJob(rule *pb.Rule, triggerType string, ctx context.Context) *RuleJob

+ type Watcher struct

+ func NewWatcher(rule *pb.Rule, configPath string, verbose bool) *Watcher

+ func (w *Watcher) GetWatchedDirectories() []string

+ func (w *Watcher) SetEventHandler(handler func(string))

+ func (w *Watcher) Start() error

+ func (w *Watcher) Stop() error

+ type Worker struct

+ func NewWorker(id int, orchestrator *Orchestrator) *Worker

+ func (w *Worker) Start(jobQueue <-chan *RuleJob, workerPool *WorkerPool)

+ func (w *Worker) Stop() error

+ func (w *Worker) TerminateProcesses() error

+ type WorkerPool struct

+ func NewWorkerPool(orchestrator *Orchestrator, maxWorkers int) *WorkerPool

+ func (wp *WorkerPool) CompleteJob(job *RuleJob, worker *Worker)

+ func (wp *WorkerPool) EnqueueJob(job *RuleJob)

+ func (wp *WorkerPool) GetExecutingRules() map[string]int

+ func (wp *WorkerPool) GetPendingRules() []string

+ func (wp *WorkerPool) GetStatus() (active int, capacity int, pending int, executing int)

+ func (wp *WorkerPool) Start() error

+ func (wp *WorkerPool) Stop() error

Jul 13, 2025

Changes in this version

+ type CycleBreaker struct

+ func NewCycleBreaker() *CycleBreaker

+ func (cb *CycleBreaker) CleanupOldData()

+ func (cb *CycleBreaker) DisableRule(ruleName string, duration time.Duration)

+ func (cb *CycleBreaker) GenerateCycleResolutionSuggestions(ruleName string, cycleType string) []string

+ func (cb *CycleBreaker) GetDisabledRules() map[string]time.Time

+ func (cb *CycleBreaker) GetEmergencyBreakCount(ruleName string) int

+ func (cb *CycleBreaker) IsRuleDisabled(ruleName string) bool

+ func (cb *CycleBreaker) TriggerEmergencyBreak(ruleName string)

+ type FileModificationTracker struct

+ func NewFileModificationTracker() *FileModificationTracker

+ func (fmt *FileModificationTracker) CleanupOldModifications(maxAge time.Duration)

+ func (fmt *FileModificationTracker) GetModificationCount(filePath string, windowSeconds uint32) int

+ func (fmt *FileModificationTracker) GetThrashingFiles(windowSeconds, threshold uint32) []string

+ func (fmt *FileModificationTracker) IsFileThrashing(filePath string, windowSeconds, threshold uint32) bool

+ func (fmt *FileModificationTracker) RecordModification(filePath string)

type Orchestrator

+ func (o *Orchestrator) ValidateConfig() error

type RuleRunner

+ func (r *RuleRunner) CleanupTriggerHistory()

+ func (r *RuleRunner) GetTriggerCount(duration time.Duration) int

+ func (r *RuleRunner) GetTriggerRate() float64

+ func (r *RuleRunner) TriggerDebouncedWithOptions(bypassRateLimit bool)

+ type TriggerChain struct

+ func NewTriggerChain() *TriggerChain

+ func (tc *TriggerChain) CleanupOldChains()

+ func (tc *TriggerChain) DetectCycle(sourceRule, targetRule string, maxDepth uint32) bool

+ func (tc *TriggerChain) GetChainLength(ruleName string) int

+ func (tc *TriggerChain) RecordTrigger(sourceRule, targetRule string)

+ type TriggerTracker struct

+ func NewTriggerTracker() *TriggerTracker

+ func (t *TriggerTracker) CleanupOldTriggers(duration time.Duration)

+ func (t *TriggerTracker) GetBackoffLevel() int

+ func (t *TriggerTracker) GetLastTrigger() *time.Time

+ func (t *TriggerTracker) GetTriggerCount(duration time.Duration) int

+ func (t *TriggerTracker) GetTriggerRate() float64

+ func (t *TriggerTracker) IsInBackoff() bool

+ func (t *TriggerTracker) RecordTrigger()

+ func (t *TriggerTracker) ResetBackoff()

+ func (t *TriggerTracker) SetBackoff()

Jul 7, 2025

Changes in this version

+ func MatcherMatches(m *pb.RuleMatcher, filePath string) bool

+ func RuleMatches(r *pb.Rule, filePath string) *pb.RuleMatcher

+ type AgentService struct

+ func NewAgentService(orch *Orchestrator) *AgentService

+ func (s *AgentService) GetConfig(ctx context.Context, req *protos.GetConfigRequest) (resp *protos.GetConfigResponse, err error)

+ func (s *AgentService) GetRule(ctx context.Context, req *protos.GetRuleRequest) (resp *protos.GetRuleResponse, err error)

+ func (s *AgentService) ListWatchedPaths(ctx context.Context, req *protos.ListWatchedPathsRequest) (resp *protos.ListWatchedPathsResponse, err error)

+ func (s *AgentService) StreamLogs(req *protos.StreamLogsRequest, ...) error

+ func (s *AgentService) TriggerRule(ctx context.Context, req *protos.TriggerRuleRequest) (resp *protos.TriggerRuleResponse, err error)

+ type Rule struct

+ func (r *Rule) GetColor() string

+ func (r *Rule) GetName() string

+ func (r *Rule) GetPrefix() string

+ type RuleStatus struct

+ type Settings struct

+ func (s *Settings) GetColorLogs() bool

+ func (s *Settings) GetColorScheme() string

+ func (s *Settings) GetCustomColors() map[string]string

Jul 3, 2025

Changes in this version

+ func StripColorCodes(input string) string

+ type ColorManager struct

+ func NewColorManager(settings *gateway.Settings) *ColorManager

+ func (cm *ColorManager) DisableColors()

+ func (cm *ColorManager) FormatPrefix(prefix string, rule *gateway.Rule) string

+ func (cm *ColorManager) GetColorForRule(rule *gateway.Rule) *color.Color

+ func (cm *ColorManager) GetColoredString(text string, rule *gateway.Rule) string

+ func (cm *ColorManager) IsEnabled() bool

+ type ColoredPrefixWriter struct

+ func NewColoredPrefixWriter(writers []io.Writer, prefix string, colorManager *ColorManager, ...) *ColoredPrefixWriter

+ func (cpw *ColoredPrefixWriter) UpdatePrefix(newPrefix string)

+ func (cpw *ColoredPrefixWriter) Write(p []byte) (n int, err error)

+ func (cpw *ColoredPrefixWriter) WriteToFileOnly(p []byte) (n int, err error)

+ func (cpw *ColoredPrefixWriter) WriteToTerminalOnly(p []byte) (n int, err error)

type Orchestrator

+ ColorManager *ColorManager

type OrchestratorV2

+ ColorManager *ColorManager

Jul 3, 2025

Changes in this version

+ func LoadConfig(configPath string) (*gateway.Config, error)

+ type LogManager struct

+ func NewLogManager(logDir string) (*LogManager, error)

+ func (lm *LogManager) Close() error

+ func (lm *LogManager) GetWriter(ruleName string) (io.Writer, error)

+ func (lm *LogManager) SignalFinished(ruleName string)

+ func (lm *LogManager) StreamLogs(ruleName, filter string, stream pb.GatewayClientService_StreamLogsClientServer) error

+ type Orchestrator struct

+ Config *gateway.Config

+ ConfigPath string

+ LogManager *LogManager

+ Verbose bool

+ Watcher *fsnotify.Watcher

+ func NewOrchestrator(configPath string, gatewayAddr string) (*Orchestrator, error)

+ func (o *Orchestrator) GetConfig() *gateway.Config

+ func (o *Orchestrator) GetRuleStatus(ruleName string) (*gateway.RuleStatus, bool)

+ func (o *Orchestrator) GetWatchedPaths() []string

+ func (o *Orchestrator) ProjectRoot() string

+ func (o *Orchestrator) ReadFileContent(path string) ([]byte, error)

+ func (o *Orchestrator) SetGlobalDebounceDelay(duration time.Duration)

+ func (o *Orchestrator) SetRuleDebounceDelay(ruleName string, duration time.Duration) error

+ func (o *Orchestrator) SetRuleVerbose(ruleName string, verbose bool) error

+ func (o *Orchestrator) SetVerbose(verbose bool)

+ func (o *Orchestrator) Start() error

+ func (o *Orchestrator) Stop() error

+ func (o *Orchestrator) StreamLogs(ruleName string, filter string, ...) error

+ func (o *Orchestrator) TriggerRule(ruleName string) error

+ type OrchestratorInterface interface

+ GetConfig func() *gateway.Config

+ GetRuleStatus func(ruleName string) (*gateway.RuleStatus, bool)

+ GetWatchedPaths func() []string

+ ProjectRoot func() string

+ ReadFileContent func(path string) ([]byte, error)

+ SetGlobalDebounceDelay func(duration time.Duration)

+ SetRuleDebounceDelay func(ruleName string, duration time.Duration) error

+ SetRuleVerbose func(ruleName string, verbose bool) error

+ SetVerbose func(verbose bool)

+ Start func() error

+ Stop func() error

+ StreamLogs func(ruleName string, filter string, ...) error

+ TriggerRule func(ruleName string) error

+ func NewOrchestratorForTesting(configPath string, gatewayAddr string) (OrchestratorInterface, error)

+ type OrchestratorV2 struct

+ Config *gateway.Config

+ ConfigPath string

+ LogManager *LogManager

+ Verbose bool

+ Watcher *fsnotify.Watcher

+ func NewOrchestratorV2(configPath string, gatewayAddr string) (*OrchestratorV2, error)

+ func (o *OrchestratorV2) GetConfig() *gateway.Config

+ func (o *OrchestratorV2) GetRuleStatus(ruleName string) (*gateway.RuleStatus, bool)

+ func (o *OrchestratorV2) GetWatchedPaths() []string

+ func (o *OrchestratorV2) ProjectRoot() string

+ func (o *OrchestratorV2) ReadFileContent(path string) ([]byte, error)

+ func (o *OrchestratorV2) SetGlobalDebounceDelay(duration time.Duration)

+ func (o *OrchestratorV2) SetRuleDebounceDelay(ruleName string, duration time.Duration) error

+ func (o *OrchestratorV2) SetRuleVerbose(ruleName string, verbose bool) error

+ func (o *OrchestratorV2) SetVerbose(verbose bool)

+ func (o *OrchestratorV2) Start() error

+ func (o *OrchestratorV2) Stop() error

+ func (o *OrchestratorV2) StreamLogs(ruleName string, filter string, ...) error

+ func (o *OrchestratorV2) TriggerRule(ruleName string) error

+ type PrefixWriter struct

+ func (pw *PrefixWriter) Write(p []byte) (n int, err error)

+ type RuleRunner interface

+ Execute func() error

+ GetRule func() gateway.Rule

+ GetStatus func() *gateway.RuleStatus

+ IsRunning func() bool

+ Restart func() error

+ SetDebounceDelay func(duration time.Duration)

+ SetVerbose func(verbose bool)

+ Start func() error

+ Stop func() error

+ TerminateProcesses func() error

+ TriggerDebounced func()

+ func NewRuleRunner(rule gateway.Rule, orchestrator *Orchestrator) RuleRunner