watcher

Documentation

Index

• type Watcher
  • func New(cfg *config.Config, src source.PlanSource, rep reporter.Reporter) *Watcher
  • func (w *Watcher) Run(ctx context.Context) error
  • func (w *Watcher) RunOnce(ctx context.Context) error

Types

type Watcher

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

func New

func New(cfg *config.Config, src source.PlanSource, rep reporter.Reporter) *Watcher

func (*Watcher) Run

func (w *Watcher) Run(ctx context.Context) error

Run reads plans continuously and flushes findings to the reporter every cfg.Interval. Blocks until ctx is cancelled.

func (*Watcher) RunOnce

func (w *Watcher) RunOnce(ctx context.Context) error

RunOnce reads all plans from src until the channel closes, then reports. Designed for one-shot mode where the source stops at EOF.