- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for BucketStats (0.23 sec)
-
internal/bucket/bandwidth/monitor_test.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 4.3K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
srProxyStats ProxyMetric bucketStats map[string]ProxyMetric sync.RWMutex // mutex for proxy stats } func newProxyStatsCache() proxyStatsCache { return proxyStatsCache{ bucketStats: make(map[string]ProxyMetric), } } func (p *proxyStatsCache) inc(bucket string, api replProxyAPI, isErr bool) { p.Lock() defer p.Unlock() v, ok := p.bucketStats[bucket] if !ok { v = ProxyMetric{}
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
if !ok { continue } bucketStats[i] = bucketStat } bucketsReplicationStats[bucket] = r.calculateBucketReplicationStats(bucket, bucketStats) } return bucketsReplicationStats } func (r *ReplicationStats) calculateBucketReplicationStats(bucket string, bucketStats []BucketStats) (bs BucketStats) { if r == nil { bs = BucketStats{ ReplicationStats: BucketReplicationStats{
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/http-stats.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
cmd/notification.go
return err } bucketStats[index] = bs return nil }, index, *client.host) } for _, nErr := range ng.Wait() { reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", nErr.Host.String()) if nErr.Err != nil { peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), nErr.Err, nErr.Host.String()) } } bucketStats = append(bucketStats, BucketStats{
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
CurrentBandwidthInBytesPerSecond float64 `json:"currentBandwidth"` } // BucketBandwidthReport captures the details for all buckets. type BucketBandwidthReport struct { BucketStats map[BucketOptions]Details `json:"bucketStats,omitempty"` } // GetReport gets the report for all bucket bandwidth details. func (m *Monitor) GetReport(selectBucket SelectionFunction) *BucketBandwidthReport { m.mlock.RLock()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0) -
cmd/bucket-stats_gen_test.go
} } func BenchmarkMarshalMsgBucketStats(b *testing.B) { v := BucketStats{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBucketStats(b *testing.B) { v := BucketStats{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts))) b.ReportAllocs()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Aug 30 08:00:59 GMT 2023 - 20.5K bytes - Viewed (0) -
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
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-stats_gen.go
return } if z.Stats == nil { z.Stats = make(map[string]BucketStats, zb0002) } else if len(z.Stats) > 0 { for key := range z.Stats { delete(z.Stats, key) } } for zb0002 > 0 { zb0002-- var za0001 string var za0002 BucketStats za0001, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Stats")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 57.5K bytes - Viewed (0) -
cmd/site-replication.go
} } for i, sri := range sris { for b := range allBuckets { if _, ok := bucketStats[b]; !ok { bucketStats[b] = make([]srBucketMetaInfo, numSites) } si, ok := sri.Buckets[b] if !ok { si = madmin.SRBucketInfo{Bucket: b} } bucketStats[b][i] = srBucketMetaInfo{SRBucketInfo: si, DeploymentID: sri.DeploymentID} } for pname := range allPolicies {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 182.7K bytes - Viewed (1)