- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for DeleteBucketThrottle (0.14 sec)
-
internal/bucket/bandwidth/monitor.go
for opts := range m.bucketsMeasurement { if opts.Name == bucket { delete(m.bucketsMeasurement, opts) } } m.mlock.Unlock() } // DeleteBucketThrottle deletes monitoring for a bucket's target func (m *Monitor) DeleteBucketThrottle(bucket, arn string) { m.tlock.Lock() delete(m.bucketsThrottle, BucketOptions{Name: bucket, ReplicationARN: arn}) m.tlock.Unlock() m.mlock.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
cmd/bucket-targets.go
sys.updateBandwidthLimit(bucket, tgt.Arn, tgt.BandwidthLimit) return nil } func (sys *BucketTargetSys) updateBandwidthLimit(bucket, arn string, limit int64) { if limit == 0 { globalBucketMonitor.DeleteBucketThrottle(bucket, arn) return } // Setup bandwidth throttling globalBucketMonitor.SetBandwidthLimit(bucket, arn, limit) } // RemoveTarget - removes a remote bucket target for this source bucket.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 20.9K bytes - Viewed (0)