Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for DeleteBucketThrottle (0.16 sec)

  1. 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()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
  2. 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
Back to top