Loading go-apps/meepctl/go.mod +0 −1 Original line number Diff line number Diff line Loading @@ -5,7 +5,6 @@ go 1.12 require ( github.com/BurntSushi/toml v0.3.1 // indirect github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-ctrl-engine-client v0.0.0 github.com/antihax/optional v1.0.0 // indirect github.com/cpuguy83/go-md2man v1.0.10 // indirect github.com/ghodss/yaml v1.0.0 github.com/inconshreveable/mousetrap v1.0.0 // indirect Loading go-packages/meep-logger/logger.go +1 −0 Original line number Diff line number Diff line Loading @@ -25,6 +25,7 @@ import ( ) var componentName string const LoggerTimeStampFormat = "2006-01-02T15:04:05.999Z07:00" type Fields map[string]interface{} Loading go-packages/meep-redis/db.go +1 −1 Original line number Diff line number Diff line Loading @@ -299,7 +299,7 @@ func (rc *Connector) Unsubscribe(channels ...string) error { return errors.New("Redis Connector is disconnected (Unsubscribe)") } if rc.pubsub != nil { rc.pubsub.Unsubscribe(channels...) _ = rc.pubsub.Unsubscribe(channels...) } return nil } Loading go-packages/meep-watchdog/pingee.go +2 −2 Original line number Diff line number Diff line Loading @@ -80,7 +80,7 @@ func (p *Pingee) Stop() (err error) { if p.isStarted { p.isStarted = false p.rc.StopListen() p.rc.Unsubscribe(p.pingChannel) _ = p.rc.Unsubscribe(p.pingChannel) log.Debug("Pignee stopped ", p.name) } return nil Loading @@ -89,5 +89,5 @@ func (p *Pingee) Stop() (err error) { func (p *Pingee) pingHandler(channel string, payload string) { pingMsg := strings.TrimPrefix(payload, pingPrefix) pongMsg := pongPrefix + pingMsg p.rc.Publish(p.pongChannel, pongMsg) _ = p.rc.Publish(p.pongChannel, pongMsg) } go-packages/meep-watchdog/pinger.go +4 −4 Original line number Diff line number Diff line Loading @@ -31,7 +31,7 @@ type Pinger struct { isStarted bool pingChannel string pongChannel string pingMsg string // pingMsg string pongMsg string rc *redis.Connector } Loading Loading @@ -83,7 +83,7 @@ func (p *Pinger) Stop() (err error) { if p.isStarted { p.isStarted = false p.rc.StopListen() p.rc.Unsubscribe(p.pongChannel) _ = p.rc.Unsubscribe(p.pongChannel) log.Debug("Pigner stopped ", p.name) } return nil Loading Loading
go-apps/meepctl/go.mod +0 −1 Original line number Diff line number Diff line Loading @@ -5,7 +5,6 @@ go 1.12 require ( github.com/BurntSushi/toml v0.3.1 // indirect github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-ctrl-engine-client v0.0.0 github.com/antihax/optional v1.0.0 // indirect github.com/cpuguy83/go-md2man v1.0.10 // indirect github.com/ghodss/yaml v1.0.0 github.com/inconshreveable/mousetrap v1.0.0 // indirect Loading
go-packages/meep-logger/logger.go +1 −0 Original line number Diff line number Diff line Loading @@ -25,6 +25,7 @@ import ( ) var componentName string const LoggerTimeStampFormat = "2006-01-02T15:04:05.999Z07:00" type Fields map[string]interface{} Loading
go-packages/meep-redis/db.go +1 −1 Original line number Diff line number Diff line Loading @@ -299,7 +299,7 @@ func (rc *Connector) Unsubscribe(channels ...string) error { return errors.New("Redis Connector is disconnected (Unsubscribe)") } if rc.pubsub != nil { rc.pubsub.Unsubscribe(channels...) _ = rc.pubsub.Unsubscribe(channels...) } return nil } Loading
go-packages/meep-watchdog/pingee.go +2 −2 Original line number Diff line number Diff line Loading @@ -80,7 +80,7 @@ func (p *Pingee) Stop() (err error) { if p.isStarted { p.isStarted = false p.rc.StopListen() p.rc.Unsubscribe(p.pingChannel) _ = p.rc.Unsubscribe(p.pingChannel) log.Debug("Pignee stopped ", p.name) } return nil Loading @@ -89,5 +89,5 @@ func (p *Pingee) Stop() (err error) { func (p *Pingee) pingHandler(channel string, payload string) { pingMsg := strings.TrimPrefix(payload, pingPrefix) pongMsg := pongPrefix + pingMsg p.rc.Publish(p.pongChannel, pongMsg) _ = p.rc.Publish(p.pongChannel, pongMsg) }
go-packages/meep-watchdog/pinger.go +4 −4 Original line number Diff line number Diff line Loading @@ -31,7 +31,7 @@ type Pinger struct { isStarted bool pingChannel string pongChannel string pingMsg string // pingMsg string pongMsg string rc *redis.Connector } Loading Loading @@ -83,7 +83,7 @@ func (p *Pinger) Stop() (err error) { if p.isStarted { p.isStarted = false p.rc.StopListen() p.rc.Unsubscribe(p.pongChannel) _ = p.rc.Unsubscribe(p.pongChannel) log.Debug("Pigner stopped ", p.name) } return nil Loading