Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for GetClusterAllBucketStats (0.22 sec)

  1. cmd/bucket-replication-stats.go

    func (r *ReplicationStats) getAllLatest(bucketsUsage map[string]BucketUsageInfo) (bucketsReplicationStats map[string]BucketStats) {
    	if r == nil {
    		return nil
    	}
    	peerBucketStatsList := globalNotificationSys.GetClusterAllBucketStats(GlobalContext)
    	bucketsReplicationStats = make(map[string]BucketStats, len(bucketsUsage))
    
    	for bucket := range bucketsUsage {
    		bucketStats := make([]BucketStats, len(peerBucketStatsList))
    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())
    		}
    	}
    }
    
    // GetClusterAllBucketStats - returns bucket stats for all buckets from all remote peers.
    func (sys *NotificationSys) GetClusterAllBucketStats(ctx context.Context) []BucketStatsMap {
    	ng := WithNPeers(len(sys.peerClients)).WithRetries(1)
    	replicationStats := make([]BucketStatsMap, 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)
Back to top