Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getSRMetricsForNode (0.15 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top