From 6fdd32d5cecb261b8dd6909bc2aea8f35fe146bf Mon Sep 17 00:00:00 2001 From: Ben Johnson Date: Thu, 20 Aug 2015 13:15:27 -0600 Subject: [PATCH] remove core.Service --- core/service.go | 73 -------------------------------------------- dispatch/dispatch.go | 2 -- 2 files changed, 75 deletions(-) delete mode 100644 core/service.go diff --git a/core/service.go b/core/service.go deleted file mode 100644 index 4c888624b..000000000 --- a/core/service.go +++ /dev/null @@ -1,73 +0,0 @@ -package core - -import ( - "os" - "os/signal" - "syscall" - - log "github.com/cihub/seelog" - "github.com/coreos/go-etcd/etcd" - "github.com/umbel/pilosa/db" - "github.com/umbel/pilosa/hold" - "github.com/umbel/pilosa/index" - "github.com/umbel/pilosa/interfaces" - "github.com/umbel/pilosa/util" -) - -type Service struct { - Stopper - Id *util.GUID - Etcd *etcd.Client - Cluster *db.Cluster - TopologyMapper *TopologyMapper - ProcessMapper *ProcessMapper - ProcessMap *ProcessMap - Executor interfaces.Executorer - WebService *WebService - Index *index.FragmentContainer - Hold *hold.Holder - version string - name string -} - -var Build string - -func (service *Service) GetSignals() (chan os.Signal, chan os.Signal) { - hupChan := make(chan os.Signal, 1) - termChan := make(chan os.Signal, 1) - signal.Notify(hupChan, syscall.SIGHUP) - signal.Notify(termChan, syscall.SIGINT, syscall.SIGTERM) - return termChan, hupChan -} - -func (service *Service) Run() { - log.Info("Setup service...", service.version) - service.TopologyMapper.Setup() - log.Info("Running service...", service.version) - go service.TopologyMapper.Run() - go service.ProcessMapper.Run() - go service.WebService.Run() - go service.Executor.Run() - go service.Hold.Run() - - sigterm, sighup := service.GetSignals() - for { - select { - case <-sighup: - log.Info("SIGHUP! Reloading configuration...") - // TODO: reload configuration - case <-sigterm: - log.Info("SIGTERM! Cleaning up...") - service.Index.Shutdown() - service.WebService.Shutdown() - util.ShutdownStats() - service.Stop() - return - } - } - log.Info("Service stopping") -} - -type Message interface { - Handle(*Service) -} diff --git a/dispatch/dispatch.go b/dispatch/dispatch.go index c1eb56258..7ea06632a 100644 --- a/dispatch/dispatch.go +++ b/dispatch/dispatch.go @@ -31,8 +31,6 @@ type Dispatch struct { Receive() *db.Message Send(message *db.Message, host *util.GUID) } - - service *core.Service } func NewDispatch() *Dispatch {