Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,248 for deletes (0.38 sec)

  1. cmd/xl-storage.go

    	for k := range foundDirs {
    		delete(foundDirs, k)
    	}
    
    	// Populate into map
    	for _, k := range dirs {
    		foundDirs[k] = struct{}{}
    	}
    
    	// Delete all directories we expect to be there.
    	for _, dir := range wantDirs {
    		delete(foundDirs, dir)
    	}
    
    	// Nothing to delete
    	if len(foundDirs) == 0 {
    		return nil
    	}
    
    	// Delete excessive inline entries.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  2. internal/config/config.go

    func (kvs KVS) Get(key string) string {
    	v, ok := kvs.Lookup(key)
    	if ok {
    		return v
    	}
    	return ""
    }
    
    // Delete - deletes the key if present from the KV list.
    func (kvs *KVS) Delete(key string) {
    	for i, kv := range *kvs {
    		if kv.Key == key {
    			*kvs = append((*kvs)[:i], (*kvs)[i+1:]...)
    			return
    		}
    	}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	globalEventNotifier.RemoveNotification(bucketName)
    	globalBucketConnStats.delete(bucketName)
    	globalBucketHTTPStats.delete(bucketName)
    	if localMetacacheMgr != nil {
    		localMetacacheMgr.deleteBucketCache(bucketName)
    	}
    	return
    }
    
    // GetAllBucketStatsHandler - fetches bucket replication stats for all buckets from this peer.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  4. cmd/veeam-sos-api.go

    //     Optional value, default 64, range: 1-unlimited
    //
    //   - <S3MultiObjectDeleteLimit>
    //     Some of the Veeam products use Multi Delete operations. This setting can reduce how many objects are included in one
    //     multi-delete operation. The same registry key setting overwrites the storage-defined setting.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 18:43:58 GMT 2024
    - 8.2K bytes
    - Viewed (2)
  5. internal/kms/kes.go

    	c.lock.RLock()
    	defer c.lock.RUnlock()
    
    	return c.client.CreateKey(ctx, keyID)
    }
    
    // DeleteKey deletes a key at the KMS with the given key ID.
    // Please note that is a dangerous operation.
    // Once a key has been deleted all data that has been encrypted with it cannot be decrypted
    // anymore, and therefore, is lost.
    func (c *kesClient) DeleteKey(ctx context.Context, keyID string) error {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 16 15:43:39 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  6. cmd/iam-store.go

    			// Delete this user account and its policy mapping
    			store.deleteMappedPolicy(ctx, user, userType, false)
    			cache.iamUserPolicyMap.Delete(user)
    
    			// we are only logging errors, not handling them.
    			err := store.deleteUserIdentity(ctx, user, userType)
    			iamLogIf(GlobalContext, err)
    			delete(cache.iamUsersMap, user)
    
    			deleted = true
    		}
    	}
    
    	if deleted {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  7. cmd/bucket-replication-stats.go

    		select {
    		case <-ctx.Done():
    			return
    		case <-r.qTimer.C:
    			r.qCache.update()
    		}
    	}
    }
    
    // Delete deletes in-memory replication statistics for a bucket.
    func (r *ReplicationStats) Delete(bucket string) {
    	if r == nil {
    		return
    	}
    
    	r.Lock()
    	defer r.Unlock()
    	delete(r.Cache, bucket)
    }
    
    // UpdateReplicaStat updates in-memory replica statistics with new values.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  8. internal/bucket/replication/replication.go

    			return false
    		}
    		if obj.OpType == DeleteReplicationType {
    			switch {
    			case obj.VersionID != "":
    				// check MinIO extension for versioned deletes
    				return rule.DeleteReplication.Status == Enabled
    			default:
    				return rule.DeleteMarkerReplication.Status == Enabled
    			}
    		} // regular object/metadata replication
    		return rule.MetadataReplicate(obj)
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

        }
        return false
      }
    
      /**
       * Closes the cache and deletes all of its stored values. This will delete all files in the cache
       * directory including files that weren't created by the cache.
       */
      @Throws(IOException::class)
      fun delete() {
        close()
        fileSystem.deleteContents(directory)
      }
    
      /**
       * Deletes all stored values from the cache. In-flight edits will complete normally but their
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 34.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/io/MoreFilesTest.java

            assertEquals(
                "contents of directory " + path + " not deleted with delete method " + this,
                0,
                MoreFiles.listFiles(path).size());
          }
        },
        DELETE_RECURSIVELY {
          @Override
          public void delete(Path path, RecursiveDeleteOption... options) throws IOException {
            MoreFiles.deleteRecursively(path, options);
          }
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Jan 29 22:57:05 GMT 2024
    - 27.2K bytes
    - Viewed (0)
Back to top