watch

type Event ¶

type Event struct {
	Name string
	Op   Op
}

Event describes a file change that affects `Name`

type Op ¶

type Op uint32

Op describes a file operation on a watched object. In addition to the fsnotify events, an op mask of DirChild indicates that the event occurred in a watched directory rather than for a watched file itself.

const (
	Create Op = 1 << iota
	Write
	Remove
	Rename
	Chmod
	DirChild
)

func (op Op) String() string

type Shutdown ¶

type Shutdown interface {
	// Waits for a close event.
	Dying() <-chan struct{}

	// Kill the application, which triggers all waiters on shutdown.Dying()
	// to receive a close event.
	Kill(error)
}

Shutdown is an interface that provides a safe shutdown mechansim. The interface is compatible with tomb.Tomb.

Most channel operations should include a select on Shutdown.Dying() inorder to cleanly exit:

select {
  case <-shutdown.Dying():
    return
}

func NewShutdown() Shutdown

type Tail ¶

type Tail struct {
	Filename string
	// contains filtered or unexported fields
}

Tail maintains a tail-capable file buffer.

func TailFile(filename string) (*Tail, error)

func (t *Tail) Close()

func (t *Tail) ProcessLines(process func(line string) error) error

func (t *Tail) ReadLines() ([]string, error)

func (t *Tail) SendLines(lines chan string, shutdown Shutdown) error

type Watcher ¶

type Watcher struct {
	Events chan Event
	// contains filtered or unexported fields
}

Watcher watches a directory or file and guards against multiple watching events by tracking the registered set, which fsnotify does not do.

func MakeWatcher() *Watcher

func (w *Watcher) AddWatch(fname string) error

func (w *Watcher) Close()

func (w *Watcher) RemoveWatch(fname string) error

func (w *Watcher) RunLoop(shutdown Shutdown)