dragonflyoss
/
dragonfly
mirror of https://github.com/dragonflyoss/dragonfly.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: manager PeerGauge (#1761) 

Signed-off-by: Gaius <gaius.qi@gmail.com>
This commit is contained in:
Gaius 2022-10-14 15:51:21 +08:00
parent aac5ade4e2
commit 0a870e0844
No known key found for this signature in database
GPG Key ID: 8B4E5D1290FA2FFB
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
manager/rpcserver/rpcserver.go
View File

@ -513,7 +513,10 @@ func (s *Server) ListSchedulers(ctx context.Context, req *managerv1.ListSchedule
// Count the number of the active peer. // Count the number of the active peer.
if s.config.Metrics.EnablePeerGauge && req.SourceType == managerv1.SourceType_PEER_SOURCE { if s.config.Metrics.EnablePeerGauge && req.SourceType == managerv1.SourceType_PEER_SOURCE {
peerCacheKey := fmt.Sprintf("%s-%s", req.HostName, req.Ip) peerCacheKey := fmt.Sprintf("%s-%s", req.HostName, req.Ip)
if _, _, found := s.peerCache.GetWithExpiration(peerCacheKey); !found { if data, _, found := s.peerCache.GetWithExpiration(peerCacheKey); !found {
metrics.PeerGauge.WithLabelValues(req.Version, req.Commit).Inc()
} else if cache, ok := data.(*managerv1.ListSchedulersRequest); ok && (cache.Version != req.Version || cache.Commit != req.Commit) {
metrics.PeerGauge.WithLabelValues(cache.Version, cache.Commit).Dec()
metrics.PeerGauge.WithLabelValues(req.Version, req.Commit).Inc() metrics.PeerGauge.WithLabelValues(req.Version, req.Commit).Inc()
} }