watcher

package

v1.9.2 Latest Latest Go to latest Published: Sep 18, 2024 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewDirectoryWatcher(scanInterval, retry int) *DirectoryWatcher

func (w *DirectoryWatcher) Close()

func (w *DirectoryWatcher) Done(record *NewRecord)

func (w *DirectoryWatcher) Error(record *NewRecord)

func (w *DirectoryWatcher) Watch(dir string, parser parser.Parser) <-chan *NewRecord

type NewRecord struct {
	*api.NewRecord
	PdfPath      string
	RetryCounter int
}

type Watcher interface {
	Watch(dir string, parser parser.Parser) <-chan *api.NewRecord
	Done(record *api.NewRecord)
}