watcher

Documentation

Index

• type IFace
• type Watcher
  • func New(path string) (w *Watcher)
  • func (w *Watcher) Close()
  • func (w *Watcher) Init() error
  • func (w *Watcher) ReadFile() ([]byte, error)
  • func (w *Watcher) Register(cb func(bts []byte))
  • func (w *Watcher) UpdateBytes() error
  • func (w *Watcher) Watch()

Types

type IFace

type IFace interface {
	Init() error
	Watch()
	Register(func(bts []byte))
	UpdateBytes() error
	ReadFile() ([]byte, error)
}

IFace interface for the the file system watcher.

type Watcher

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

Watcher is a wrapper for `fsnotify` that provides the registration of a callback for WRITE events. It uses a 5 second polling fallback to periodically reload dcdr file changes, in the event that the watcher does not fire.

func New

func New(path string) (w *Watcher)

New initializes a Watcher and verifies that `path` exists.

func (*Watcher) Close

func (w *Watcher) Close()

func (*Watcher) Init

func (w *Watcher) Init() error

Init creates a new `fsnotify` watcher observing `path`.

func (*Watcher) ReadFile

func (w *Watcher) ReadFile() ([]byte, error)

ReadFile reads the contents of `path`.

func (*Watcher) Register

func (w *Watcher) Register(cb func(bts []byte))

Register assigns the WRITE event callback.

func (*Watcher) UpdateBytes

func (w *Watcher) UpdateBytes() error

UpdateBytes reads the contents of `path` and passes the bytes to `writeCallback`.

func (*Watcher) Watch

func (w *Watcher) Watch()