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

wip

Browse source
This commit is contained in:
Sebastien Blot 2021-04-30 17:39:35 +02:00
parent 3b084ee8b8
commit 14f66b7527
No known key found for this signature in database
GPG key ID: DFC2902F40449F6A
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -183,11 +183,15 @@ func (f *FileSource) GetMetrics() []prometheus.Collector {
return nil
}
func (f *FileSource) GetName() string {
return "file"
}
func (f *FileSource) CanRun() error {
return nil
}
func (f *FileSource) LiveAcquisition(out chan types.Event, t *tomb.Tomb) error {
func (f *FileSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error {
f.logger.Debug("Starting live acquisition")
t.Go(func() error {
return f.monitorNewFiles(out, t)