toolbar/precog/monitor/monitor.go

   1 package monitor
   2
   3 import (
   4         "time"
   5
   6         "github.com/jinzhu/gorm"
   7         log "github.com/sirupsen/logrus"
   8
   9         "github.com/vapor/toolbar/precog/config"
  10 )
  11
  12 // TODO: put in cfg?
  13 const checkFreqSeconds = 60
  14
  15 type monitor struct {
  16         cfg *config.Config
  17         db  *gorm.DB
  18 }
  19
  20 func NewMonitor(cfg *config.Config, db *gorm.DB) *monitor {
  21         return &monitor{
  22                 cfg: cfg,
  23                 db:  db,
  24         }
  25 }
  26
  27 func (s *monitor) Run() {
  28         if err := s.updateNodesHostPort(); err != nil {
  29                 log.Fatal(err)
  30         }
  31
  32         ticker := time.NewTicker(checkFreqSeconds * time.Second)
  33         for ; true; <-ticker.C {
  34         }
  35 }
  36
  37 func (s *monitor) updateNodesHostPort() error {
  38         return nil
  39 }