0ct0pu5/crowdsec
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Sebastien Blot 2021-04-29 14:24:47 +02:00
parent b1c409a534
commit 7545d9c275
No known key found for this signature in database
GPG key ID: DFC2902F40449F6A
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pkg/acquisition/modules/file/file.go
View file

@ -43,7 +43,7 @@ func (f *FileSource) Configure(Config []byte, logger *log.Entry) error {
f.logger = logger
f.watchedDirectories = make(map[string]bool)
f.tails = make(map[string]bool)
err := yaml.Unmarshal(Config, &fileConfig)
err := yaml.UnmarshalStrict(Config, &fileConfig)
if err != nil {
return errors.Wrap(err, "[fileacquisition] Cannot parse FileAcquisition configuration")
}
@ -141,6 +141,14 @@ func (f *FileSource) LiveAcquisition(out chan types.Event, t *tomb.Tomb) error {
return nil
}
func (f *FileSource) Dump() *FileSource {
return f
}
func (f *FileSource) New() FileSource {
return FileSource{}
}
func (f *FileSource) monitorNewFiles(out chan types.Event, t *tomb.Tomb) error {
for {
select {