- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getSRMetricsForNode (0.3 sec)
-
cmd/bucket-replication-stats.go
r.RUnlock() for k, v := range bucketReplicationStats { v.QStat = r.qCache.getBucketStats(k) bucketReplicationStats[k] = v } return bucketReplicationStats } func (r *ReplicationStats) getSRMetricsForNode() SRMetricsSummary { if r == nil { return SRMetricsSummary{} } m := SRMetricsSummary{ Uptime: UTCNow().Unix() - globalBootTime.Unix(), Queued: r.qCache.getSiteStats(),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/notification.go
if nErr.Err != nil { peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), nErr.Err, nErr.Host.String()) } } siteStats = append(siteStats, globalReplicationStats.Load().getSRMetricsForNode()) return siteStats } // ReloadPoolMeta reloads on disk updates on pool metadata func (sys *NotificationSys) ReloadPoolMeta(ctx context.Context) { ng := WithNPeers(len(sys.peerClients))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
objAPI := newObjectLayerFn() if objAPI == nil { return nil, grid.NewRemoteErr(errServerNotInitialized) } if st := globalReplicationStats.Load(); st != nil { sm := st.getSRMetricsForNode() return &sm, nil } return &SRMetricsSummary{}, nil } // LoadBucketMetadataHandler - reloads in memory bucket metadata
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0)