filewatcher

Documentation

Index

• Variables
• type FileWatcher
  • func New(fsConfig nwfs.Config, indexer indexer.Indexer, parseFunc ParseFunc, ...) (FileWatcher, error)
  • func (f *FileWatcher) Run()
• type IIndexer
• type ParseFunc

Variables

var (
	ErrIgnorableNews = fmt.Errorf("ignorable news")
)

Types

type FileWatcher

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

FileWatcher watches for new files in a directory, parses them using parseFunc and indexes them using indexer. If PreIndexProcessor is set, it is called before indexing.

func New

func New(fsConfig nwfs.Config, indexer indexer.Indexer, parseFunc ParseFunc, logger ecslogger.ILogger) (FileWatcher, error)

New creates a new Fly instance.

func (*FileWatcher) Run

func (f *FileWatcher) Run()

Run starts the FileWatcher instance.

type IIndexer

type IIndexer interface {
	Index(news *nwelastic.News) error
}

type ParseFunc

type ParseFunc func(newFile nwfs.NewFile) (nwelastic.News, error)