Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for bucketStatsMap (0.06 sec)

  1. cmd/bucket-stats_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgBucketStatsMap(b *testing.B) {
    	v := BucketStatsMap{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBucketStatsMap(b *testing.B) {
    	v := BucketStatsMap{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	getAllBucketStatsRPC           = grid.NewSingleHandler[*grid.MSS, *BucketStatsMap](grid.HandlerGetAllBucketStats, grid.NewMSS, func() *BucketStatsMap { return &BucketStatsMap{} })
    	getBackgroundHealStatusRPC     = grid.NewSingleHandler[*grid.MSS, *grid.JSON[madmin.BgHealState]](grid.HandlerBackgroundHealStatus, grid.NewMSS, madminBgHealState.NewJSON)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
  3. cmd/bucket-stats.go

    		return
    	}
    	for l.LastMin != t {
    		// Clear next element.
    		idx := (l.LastMin + 1) % 60
    		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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  4. cmd/notification.go

    		}
    	}
    
    	replicationStatsList := globalReplicationStats.Load().GetAll()
    	bucketStatsMap := BucketStatsMap{
    		Stats:     make(map[string]BucketStats, len(replicationStatsList)),
    		Timestamp: UTCNow(),
    	}
    	for k, replicationStats := range replicationStatsList {
    		bucketStatsMap.Stats[k] = BucketStats{
    			ReplicationStats: replicationStats,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  5. cmd/bucket-stats_gen.go

    		s += z.QueueStats.Nodes[za0001].Msgsize()
    	}
    	s += 7 + msgp.Int64Size + 11 + z.ProxyStats.Msgsize()
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BucketStatsMap) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 57.3K bytes
    - Viewed (0)
  6. cmd/peer-rest-client.go

    }
    
    // GetAllBucketStats - load replication stats for all buckets
    func (client *peerRESTClient) GetAllBucketStats(ctx context.Context) (BucketStatsMap, error) {
    	resp, err := getAllBucketStatsRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return BucketStatsMap{}, err
    	}
    	return *resp, nil
    }
    
    // LoadBucketMetadata - load bucket metadata
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
Back to top