only operate on clients that are the same as the server

This commit is contained in:
Asim Aslam 2019-08-13 16:08:56 +01:00
parent c39591af0e
commit 7ce0305db4

View File

@ -41,6 +41,13 @@ func (m *monitor) check(service string) (*Status, error) {
// iterate through multiple versions of a service
for _, service := range services {
for _, node := range service.Nodes {
// TODO: checks that are not just RPC based
// TODO: better matching of the protocol
// TODO: maybe everything has to be a go-micro service?
if node.Metadata["server"] != m.client.String() {
continue
}
rsp, err := debug.Health(
context.Background(),
// empty health request