base watcher implementation

1 files changed, 39 insertions, 11 deletions

diff --git a/watcher.go b/watcher.go
index 05b8a659..3b654c34 100644
--- a/watcher.go
+++ b/watcher.go
@@ -1,22 +1,50 @@
 package roadrunner
 
 import (
-	"sync"
+	"log"
 	"time"
 )
 
-// Watcher watches for workers.
-type Watcher interface {
-	// Keep must return true and nil if worker is OK to continue working,
-	// must return false and optional error to force worker destruction.
-	Keep(p Pool, w *Worker) (keep bool, err error)
-}
-
 // disconnect??
-type LazyWatcher struct {
+type Watcher struct {
 	// defines how often
 	interval time.Duration
+	pool     Pool
+
+	stop chan interface{}
+}
+
+// NewWatcher creates new pool watcher.
+func NewWatcher(p Pool, i time.Duration) *Watcher {
+	w := &Watcher{
+		interval: i,
+		pool:     p,
+		stop:     make(chan interface{}),
+	}
+
+	go func() {
+		ticker := time.NewTicker(w.interval)
+
+		for {
+			select {
+			case <-ticker.C:
+				w.update()
+			case <-w.stop:
+				return
+			}
+		}
+	}()
+
+	return w
+}
+
+func (w *Watcher) Stop() {
+	close(w.stop)
+}
+
+func (w *Watcher) update() {
+	for _, w := range w.pool.Workers() {
+		log.Println(w)
 
-	mu sync.Mutex
-	p  Pool
+	}
 }