Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getSRMetricsForNode (0.9 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top