filesystem

Documentation

Index

• type FileContentHandler
• type FileWatcher
  • func NewFileWatcher(purpose string, path string, handler FileContentHandler) *FileWatcher
  • func (f *FileWatcher) Watch(ctx context.Context) error

Types

type FileContentHandler

type FileContentHandler func(content []byte) error

type FileWatcher

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

FileWatcher watches a single file and trigger the given handler function

func NewFileWatcher

func NewFileWatcher(purpose string, path string, handler FileContentHandler) *FileWatcher

NewFileWatcher creates a FileWatcher

func (*FileWatcher) Watch

func (f *FileWatcher) Watch(ctx context.Context) error

Watch sets up the fsnotify watcher and add the file that we are interested in. The file watcher and worker run in goroutines. The goroutines are stopped when the ctx is cancelled.