From f00529bb5888209cfca9aeabd2276e65fb5e5315 Mon Sep 17 00:00:00 2001 From: Gabriel Augendre Date: Tue, 20 Nov 2018 10:29:28 +0100 Subject: [PATCH] Add more logging --- beater/youtubebeat.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/beater/youtubebeat.go b/beater/youtubebeat.go index 06d7461..6d42a47 100644 --- a/beater/youtubebeat.go +++ b/beater/youtubebeat.go @@ -93,6 +93,7 @@ func scrapeVideos(b *beat.Beat, bt *Youtubebeat, done chan bool) { videoCollector.Visit(BaseUrl + BaseSuffix + bt.config.StartId) videoCollector.Wait() + logp.Info("Done parsing all videos") done <- true } @@ -111,8 +112,10 @@ func (bt *Youtubebeat) Run(b *beat.Beat) error { select { case <-done: + logp.Info("Exiting on done parsing") return nil case <-bt.done: + logp.Info("Exiting on beat stop signal") return nil } }