diff options
Diffstat (limited to 'service/reload/service.go')
| -rw-r--r-- | service/reload/service.go | 58 |
1 files changed, 47 insertions, 11 deletions
diff --git a/service/reload/service.go b/service/reload/service.go index ee2aed99..78f147b7 100644 --- a/service/reload/service.go +++ b/service/reload/service.go @@ -3,6 +3,7 @@ package reload import ( "github.com/spiral/roadrunner/service" "os" + "time" ) // ID contains default service name. @@ -10,18 +11,12 @@ const ID = "reload" type Service struct { reloadConfig *Config + container service.Container } // Init controller service func (s *Service) Init(cfg *Config, c service.Container) (bool, error) { - // mount Services to designated services - //for id, watcher := range cfg.Controllers(s.throw) { - // svc, _ := c.Get(id) - // if ctrl, ok := svc.(controllable); ok { - // ctrl.Attach(watcher) - // } - //} - + s.container = c s.reloadConfig = cfg return true, nil @@ -33,11 +28,52 @@ func (s *Service) Serve() error { return err } - name , _ := os.Getwd() + name , err := os.Getwd() + if err != nil { + return err + } + + err = w.AddSingle(name) + if err != nil { + return err + } - w.AddSingle(name) + go func() { + err = w.StartPolling(time.Second) + if err != nil { + + } + }() + + + + // read events and restart corresponding services + + + for { + select { + case e := <- w.Event: + println(e.Name()) + } + } + //for e = range w.Event { + // + // println("event") + // // todo use status + // //svc, _ := s.container.Get("http") + // //if svc != nil { + // // if srv, ok := svc.(service.Service); ok { + // // srv.Stop() + // // err = srv.Serve() + // // if err != nil { + // // return err + // // } + // // } + // //} + // + // //println("event skipped due to service is nil") + //} - println("test") return nil } |