watcher

package

v1.10.0 Latest Latest Go to latest Published: Oct 3, 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(dir string, parser parser.Parser, scanInterval time.Duration, retry int) *DirectoryWatcher

func (w *DirectoryWatcher) Close()

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

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

func (w *DirectoryWatcher) Watch() <-chan *NewRecord

type NewRecord struct {
	*api.NewRecord
	PdfPath      string
	RetryCounter int
	// contains filtered or unexported fields
}

func (r *NewRecord) Done()

func (r *NewRecord) Error()

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