Discovery Nats automate
This commit is contained in:
@@ -55,19 +55,19 @@ func (p *PeerCache) checkPeerStatus(peerID string, caller *tools.HTTPCaller) boo
|
||||
return false
|
||||
}
|
||||
methods := caller.URLS[utils.PEER.String()]
|
||||
fmt.Println("checkPeerStatus AFT 3", methods)
|
||||
|
||||
if methods == nil {
|
||||
return false
|
||||
}
|
||||
meth := methods[tools.POST]
|
||||
fmt.Println("checkPeerStatus AFT 4", meth)
|
||||
if meth == "" {
|
||||
return false
|
||||
}
|
||||
url := p.urlFormat(res.(*Peer).Url+meth, utils.PEER)
|
||||
fmt.Println("checkPeerStatus AFT 4", url)
|
||||
state := api.CheckRemotePeer(url)
|
||||
res.(*Peer).State = state
|
||||
access.UpdateOne(res, peerID)
|
||||
fmt.Printf("Peer %v is %v\n", peerID, state)
|
||||
return state != tools.DEAD
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user