Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for DeleteBucket (0.15 sec)

  1. internal/bucket/bandwidth/monitor.go

    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    
    	_, ok := m.bucketsMeasurement[opts]
    	if !ok {
    		m.bucketsMeasurement[opts] = newBucketMeasurement(time.Now())
    	}
    }
    
    // DeleteBucket deletes monitoring the 'bucket'
    func (m *Monitor) DeleteBucket(bucket string) {
    	m.tlock.Lock()
    	for opts := range m.bucketsThrottle {
    		if opts.Name == bucket {
    			delete(m.bucketsThrottle, opts)
    		}
    	}
    	m.tlock.Unlock()
    
    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/site-replication-utils.go

    			st.LastUpdate = UTCNow()
    			sm.resyncStatus[o.resyncID] = st
    		}
    	}
    }
    
    // remove deleted bucket from active resync tracking
    func (sm *siteResyncMetrics) deleteBucket(b string) {
    	if !globalSiteReplicationSys.isEnabled() {
    		return
    	}
    	sm.Lock()
    	defer sm.Unlock()
    	for _, rs := range sm.peerResyncMap {
    		st, ok := sm.resyncStatus[rs.resyncID]
    		if !ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.9K bytes
    - Viewed (1)
Back to top