- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for BucketStats (0.17 sec)
-
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K 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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/http-stats.go
Go - Registered: Sun May 05 19:28:20 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 May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K 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 May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 30 08:00:59 GMT 2023 - 20.5K bytes - Viewed (0) -
cmd/peer-rest-client.go
} // GetBucketStats - load bucket statistics func (client *peerRESTClient) GetBucketStats(bucket string) (BucketStats, error) { resp, err := getBucketStatsRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTBucket: bucket, })) if err != nil || resp == nil { return BucketStats{}, err } return *resp, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K 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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
enc := json.NewEncoder(w) stats := globalReplicationStats.getLatestReplicationStats(bucket) bwRpt := globalNotificationSys.GetBandwidthReports(ctx, bucket) bwMap := bwRpt.BucketStats for arn, st := range stats.ReplicationStats.Stats { for opts, bw := range bwMap { if opts.ReplicationARN != "" && opts.ReplicationARN == arn { st.BandWidthLimitInBytesPerSecond = bw.LimitInBytesPerSecond
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 28 04:08:53 GMT 2023 - 23.2K bytes - Viewed (0)