- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for deleteBucket (0.19 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()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 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 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.8K bytes - Viewed (0)