Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 648 for deletes (0.2 sec)

  1. internal/bucket/lifecycle/lifecycle.go

    	DeleteRestoredAction
    	// DeleteRestoredVersionAction deletes a particular version that was temporarily restored
    	DeleteRestoredVersionAction
    	// DeleteAllVersionsAction deletes all versions when an object expires
    	DeleteAllVersionsAction
    
    	// ActionCount must be the last action and shouldn't be used as a regular action.
    	ActionCount
    )
    
    // DeleteRestored - Returns true if action demands delete on restored objects
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 17K bytes
    - Viewed (0)
  2. doc/next/6-stdlib/99-minor/sync/61696.md

    The [Map.Clear] method deletes all the entries, resulting in
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Apr 10 17:07:25 GMT 2024
    - 105 bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/monitor.go

    	}
    }
    
    // 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()
    
    	m.mlock.Lock()
    	for opts := range m.bucketsMeasurement {
    		if opts.Name == bucket {
    			delete(m.bucketsMeasurement, opts)
    		}
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
  4. cmd/peer-s3-client.go

    		if poolErr != nil && !errors.Is(poolErr, errVolumeNotFound) {
    			if !opts.NoRecreate {
    				// re-create successful deletes, since we are return an error.
    				sys.MakeBucket(ctx, bucket, MakeBucketOptions{})
    			}
    			return toObjectErr(poolErr, bucket)
    		}
    	}
    	return nil
    }
    
    // DeleteBucket deletes bucket on a peer
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  5. internal/store/queuestore.go

    		return item, err
    	}
    
    	return item, nil
    }
    
    // Del - Deletes an entry from the store.
    func (store *QueueStore[_]) Del(key string) error {
    	store.Lock()
    	defer store.Unlock()
    	return store.del(key)
    }
    
    // DelList - Deletes a list of entries from the store.
    // Returns an error even if one key fails to be deleted.
    func (store *QueueStore[_]) DelList(keys []string) error {
    	store.Lock()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  6. internal/kms/key-manager.go

    type KeyManager interface {
    	// CreateKey creates a new key at the KMS with the given key ID.
    	CreateKey(ctx context.Context, keyID string) error
    
    	// 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.
    	DeleteKey(ctx context.Context, keyID string) error
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    	}
    	// defaults to 'strict'
    	return driveCount
    }
    
    func calcCommonWritesDeletes(infos []DiskInfo, readQuorum int) (commonWrite, commonDelete uint64) {
    	deletes := make([]uint64, len(infos))
    	writes := make([]uint64, len(infos))
    	for index, di := range infos {
    		deletes[index] = di.Metrics.TotalDeletes
    		writes[index] = di.Metrics.TotalWrites
    	}
    
    	filter := func(list []uint64) (commonCount uint64) {
    		max := 0
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  8. cmd/storage-rest-client.go

    	}
    	err = st.Results(func(resp *ListDirResult) error {
    		entries = resp.Entries
    		return nil
    	})
    	return entries, toStorageErr(err)
    }
    
    // DeleteFile - deletes a file.
    func (client *storageRESTClient) Delete(ctx context.Context, volume string, path string, deleteOpts DeleteOptions) error {
    	_, err := storageDeleteFileRPC.Call(ctx, client.gridConn, &DeleteFileHandlerParams{
    		DiskID:   *client.diskID.Load(),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Cache.kt

      fun initialize() {
        cache.initialize()
      }
    
      /**
       * 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() {
        cache.delete()
      }
    
      /**
       * Deletes all values stored in the cache. In-flight writes to the cache will complete normally,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  10. ci/official/utilities/rename_and_verify_wheels.sh

    fi
    
    # Repair wheels with auditwheel and delete the old one.
    if [[ "$TFCI_WHL_AUDIT_ENABLE" == "1" ]]; then
      python3 -m auditwheel repair --plat "$TFCI_WHL_AUDIT_PLAT" --wheel-dir . *.whl
      # if the wheel is already named correctly, auditwheel won't rename it. so we
      # list all .whl files by their modification time (ls -t) and delete anything
      # other than the most recently-modified one (the new one).
    Shell Script
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Wed Mar 27 21:16:27 GMT 2024
    - 3.4K bytes
    - Viewed (0)
Back to top