Adding base watchdog function

server/main.go

@@ -91,6 +91,10 @@ func main() {
 
 	r.loadRoutes()
 
+	watchdog := r.views.InitWatchdog()
+
+	watchdog.Begin()
+
 	log.Printf("streamer server version: %s\n", Version)
 
 	r.router.Logger.Error(r.router.Start(r.config.ServerAddress))

server/views/views.go

@@ -77,6 +77,11 @@ type (
 		// TransporterUnique is the payload to send to the client
 		TransporterUnique transporter.TransporterUnique
 	}
+
+	Watchdog struct {
+		conf  Config
+		store *store.Store
+	}
 )
 
 const (

server/views/watchdog.go

@@ -0,0 +1,24 @@
+package views
+
+import (
+	"log"
+	"time"
+)
+
+func (v *Views) InitWatchdog() *Watchdog {
+	return &Watchdog{
+		conf:  v.conf,
+		store: v.store,
+	}
+}
+
+func (w *Watchdog) Begin() {
+	go func() {
+		for {
+			if w.conf.Verbose {
+				log.Printf("watchdog called")
+			}
+			time.Sleep(5 * time.Second)
+		}
+	}()
+}