watch

Documentation

Index

• type Watcher
  • func NewWatcher(store *snapshot.SnapshotStore, engine *diff.DiffEngine, interval time.Duration) *Watcher
  • func (w *Watcher) Watch(ctx context.Context) error

Types

type Watcher

type Watcher struct {
	Store         *snapshot.SnapshotStore
	Engine        *diff.DiffEngine
	Interval      time.Duration
	InjectHeaders map[string]string // optional headers to inject (e.g. auth tokens)
}

Watcher periodically replays recorded requests and reports changes.

func NewWatcher

func NewWatcher(store *snapshot.SnapshotStore, engine *diff.DiffEngine, interval time.Duration) *Watcher

NewWatcher creates a watcher that polls the live API every interval.

func (*Watcher) Watch

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

Watch starts the monitoring loop. Blocks until context is cancelled.