Merge branch 'master' of https://git.loafle.net/overflow/overflow_probes
This commit is contained in:
commit
e9be910057
2
main.go
2
main.go
|
@ -62,7 +62,7 @@ func main() {
|
||||||
var instance interface{}
|
var instance interface{}
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
if ooccp.ProbeStateTypeNotAuthorized == config.Config.Probe.State() {
|
if ooccp.ProbeStateTypeNotAuthorized != config.Config.Probe.State() {
|
||||||
var err error
|
var err error
|
||||||
instance = auth.New()
|
instance = auth.New()
|
||||||
|
|
||||||
|
|
|
@ -60,6 +60,8 @@ func (pm *probeManagers) Start() error {
|
||||||
probeRPCRegistry.RegisterService(probeService, "")
|
probeRPCRegistry.RegisterService(probeService, "")
|
||||||
probeRPCRegistry.RegisterService(sensorService, "")
|
probeRPCRegistry.RegisterService(sensorService, "")
|
||||||
|
|
||||||
|
logging.Logger().Debug(fmt.Sprintf("%v", centralService.CentralClients))
|
||||||
|
|
||||||
if err := centralProbeClient.Connect(); nil != err {
|
if err := centralProbeClient.Connect(); nil != err {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
|
@ -13,7 +13,7 @@ func init() {
|
||||||
}
|
}
|
||||||
|
|
||||||
type CentralService struct {
|
type CentralService struct {
|
||||||
CentralClients map[string]oogwc.Client
|
CentralClients map[string]oogwc.Client `annotation:"@Resource()"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cs *CentralService) PutClient(entryPath string, c oogwc.Client) {
|
func (cs *CentralService) PutClient(entryPath string, c oogwc.Client) {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user