[fix]syncer health failure (#1322)
* [fix]syncer health failure
* [fix]syncer health failure
diff --git a/syncer/rpc/server.go b/syncer/rpc/server.go
index 5601b0a..990f789 100644
--- a/syncer/rpc/server.go
+++ b/syncer/rpc/server.go
@@ -77,6 +77,7 @@
// TODO enable to close syncer
if !config.GetConfig().Sync.EnableOnStart {
resp.Status = HealthStatusClose
+ log.Error("unexpected health check when syncer is closed", nil)
return resp, nil
}
return resp, nil
diff --git a/syncer/service/admin/health.go b/syncer/service/admin/health.go
index 5a6e1c4..60ec710 100644
--- a/syncer/service/admin/health.go
+++ b/syncer/service/admin/health.go
@@ -35,7 +35,7 @@
)
const (
- scheme = "health_rpc"
+ scheme = "grpc"
serviceName = "syncer"
)
@@ -130,7 +130,7 @@
set := client.NewSet(clientConn)
reply, err := set.EventServiceClient.Health(context.Background(), &v1sync.HealthRequest{})
if err != nil || reply == nil {
- log.Warn("health request is err")
+ log.Error("get peer health failed", err)
return rpc.HealthStatusAbnormal
}
reportClockDiff(peerName, local, reply.LocalTimestamp)
