- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for DeleteBucket (0.15 sec)
-
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) -
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)