- Sort Score
- Num 10 results
- Language All
Results 11 - 16 of 16 for bucketStats (0.5 seconds)
-
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 {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 184.8K bytes - Click Count (1) -
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 }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
cmd/bucket-stats_gen.go
} if z.Stats == nil { z.Stats = make(map[string]BucketStats, zb0002) } else if len(z.Stats) > 0 { clear(z.Stats) } for zb0002 > 0 { zb0002-- var za0001 string za0001, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Stats") return } var za0002 BucketStats err = za0002.DecodeMsg(dc) if err != nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 57.3K bytes - Click Count (0) -
cmd/bucket-replication-handlers.go
enc := json.NewEncoder(w) stats := globalReplicationStats.Load().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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 23.3K bytes - Click Count (0) -
cmd/metrics-v2.go
} metrics = append(metrics, MetricV2{ Description: getBucketUsageLastScanActivityMD(), Value: float64(time.Since(dataUsageInfo.LastUpdate)), }) var bucketReplStats map[string]BucketStats if !globalSiteReplicationSys.isEnabled() { bucketReplStats = globalReplicationStats.Load().getAllLatest(dataUsageInfo.BucketsUsage) } buckets := mapKeysSorted(dataUsageInfo.BucketsUsage)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0) -
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)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 33.3K bytes - Click Count (0)