summaryrefslogtreecommitdiff
path: root/service/watcher/watcher.go
diff options
context:
space:
mode:
Diffstat (limited to 'service/watcher/watcher.go')
-rw-r--r--service/watcher/watcher.go49
1 files changed, 0 insertions, 49 deletions
diff --git a/service/watcher/watcher.go b/service/watcher/watcher.go
index 9cf129df..8278790e 100644
--- a/service/watcher/watcher.go
+++ b/service/watcher/watcher.go
@@ -1,50 +1 @@
package watcher
-
-import (
- "log"
- "time"
-)
-
-// disconnect??
-type Service struct {
- // defines how often
- interval time.Duration
- pool Pool
-
- stop chan interface{}
-}
-
-// NewWatcher creates new pool watcher.
-func NewWatcher(p Pool, i time.Duration) *Service {
- w := &Service{
- 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 *Service) Stop() {
- close(w.stop)
-}
-
-func (w *Service) update() {
- for _, w := range w.pool.Workers() {
- log.Println(w)
-
- }
-}