Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for bucketStats (0.07 sec)

  1. cmd/http-stats.go

    	s.RLock()
    	defer s.RUnlock()
    
    	if len(s.stats) == 0 {
    		return nil
    	}
    
    	bucketStats := make(map[string]inOutBytes, len(s.stats))
    	for k, v := range s.stats {
    		bucketStats[k] = inOutBytes{
    			In:  v.s3InputBytes,
    			Out: v.s3OutputBytes,
    		}
    	}
    	return bucketStats
    }
    
    // Return S3 total input/output bytes for each
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  2. cmd/bucket-stats.go

    		l.Totals[idx] = AccElem{}
    		l.LastMin++
    	}
    }
    
    // BucketStatsMap captures bucket statistics for all buckets
    type BucketStatsMap struct {
    	Stats     map[string]BucketStats
    	Timestamp time.Time
    }
    
    // BucketStats bucket statistics
    type BucketStats struct {
    	Uptime           int64                  `json:"uptime"`
    	ReplicationStats BucketReplicationStats `json:"currStats"`  // current replication stats since cluster startup
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. cmd/notification.go

    		bucketStats = append(bucketStats, BucketStats{
    			ReplicationStats: st.Get(bucketName),
    			QueueStats:       ReplicationQueueStats{Nodes: []ReplQNodeStats{st.getNodeQueueStats(bucketName)}},
    			ProxyStats:       st.getProxyStats(bucketName),
    		})
    	}
    	return bucketStats
    }
    
    // GetClusterSiteMetrics - calls GetClusterSiteMetrics call on all peers for a cluster statistics view.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  4. cmd/peer-rest-server.go

    	getBucketStatsRPC              = grid.NewSingleHandler[*grid.MSS, *BucketStats](grid.HandlerGetBucketStats, grid.NewMSS, func() *BucketStats { return &BucketStats{} })
    	getCPUsHandler                 = grid.NewSingleHandler[*grid.MSS, *grid.JSON[madmin.CPUs]](grid.HandlerGetCPUs, grid.NewMSS, madminCPUs.NewJSON)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  5. cmd/peer-rest-client.go

    // GetBucketStats - load bucket statistics
    func (client *peerRESTClient) GetBucketStats(ctx context.Context, bucket string) (BucketStats, error) {
    	resp, err := getBucketStatsRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTBucket: bucket,
    	}))
    	if err != nil || resp == nil {
    		return BucketStats{}, err
    	}
    	return *resp, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  6. cmd/admin-bucket-handlers.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    	rpt := importMetaReport{
    		madmin.BucketMetaImportErrs{
    			Buckets: make(map[string]madmin.BucketStatus, len(zr.File)),
    		},
    	}
    
    	bucketMap := make(map[string]*BucketMetadata, len(zr.File))
    
    	updatedAt := UTCNow()
    
    	for _, file := range zr.File {
    		slc := strings.Split(file.Name, slashSeparator)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
Back to top