filewatcher

package

v0.78.1 Latest Latest Go to latest Published: Jan 7, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewLazyWatcher(root string, ignorePaths []string, logger *zap.Logger) *LazyWatcher

func (w *LazyWatcher) Close()

func (w *LazyWatcher) Subscribe(ctx context.Context, cb WatchCallback) error

type WatchCallback func(event []WatchEvent)

type WatchEvent struct {
	Type     runtimev1.FileEvent
	FullPath string
	RelPath  string
	Dir      bool
	// contains filtered or unexported fields
}

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

Watcher implements a recursive, batching file watcher on top of fsnotify.

func NewWatcher(root string, ignorePaths []string, logger *zap.Logger) (*Watcher, error)

NewWatcher creates a new watcher for the given root directory. The root directory must be an absolute path.

func (w *Watcher) Close()

func (w *Watcher) Subscribe(ctx context.Context, fn WatchCallback) error