wip
This commit is contained in:
parent
bdea3a2167
commit
8af6685a07
1 changed files with 3 additions and 4 deletions
|
@ -24,9 +24,9 @@ import (
|
|||
)
|
||||
|
||||
type FileConfiguration struct {
|
||||
Filenames []string
|
||||
Filename string
|
||||
configuration.DataSourceCommonCfg
|
||||
Filenames []string
|
||||
Filename string
|
||||
configuration.DataSourceCommonCfg `yaml:",inline"`
|
||||
}
|
||||
|
||||
type FileSource struct {
|
||||
|
@ -55,7 +55,6 @@ func (f *FileSource) Configure(Config []byte, logger *log.Entry) error {
|
|||
return fmt.Errorf("[fileacquisition] no filename or filenames configuration provided")
|
||||
}
|
||||
f.config = fileConfig
|
||||
f.config.Mode = configuration.TAIL_MODE // FIXME
|
||||
f.watcher, err = fsnotify.NewWatcher()
|
||||
if err != nil {
|
||||
return errors.Wrapf(err, "[fileacquisition] Could not create fsnotify watcher")
|
||||
|
|
Loading…
Reference in a new issue