- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getSRMetricsForNode (0.9 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 Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K 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 Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 53.4K bytes - Viewed (0)