update status

query/baseservice.go

@@ -7,6 +7,7 @@ import (
 	"github.com/odysseus/service-registry/registry"
 	"github.com/redis/go-redis/v9"
 	"sort"
+	"time"
 )
 
 type baseService struct {
@@ -62,6 +63,13 @@ func parseInfo(stype common.ServiceType, res *redis.MapStringStringCmd) ServiceI
 	if err := res.Scan(&regInfo); err != nil {
 		return nil
 	}
+	if time.Now().UnixMilli()-regInfo.Timestamp > 1000*60*1 {
+		regInfo.Status = "unhealthy"
+	}
+	if time.Now().UnixMilli()-regInfo.Timestamp > 1000*60*10 {
+		regInfo.Status = "disconnected"
+	}
+
 	return regInfo
 }