Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 406 for deletes (0.16 sec)

  1. cmd/tier-journal.go

    	VersionID string `msg:"vid"`
    	TierName  string `msg:"tier"`
    }
    
    const (
    	tierJournalVersion = 1
    	tierJournalHdrLen  = 2 // 2 bytes
    )
    
    var errUnsupportedJournalVersion = errors.New("unsupported pending deletes journal version")
    
    func newTierDiskJournal() *tierDiskJournal {
    	return &tierDiskJournal{}
    }
    
    // NewTierJournal initializes tier deletion journal
    func NewTierJournal() *TierJournal {
    	j := &TierJournal{
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K 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 May 07 11:14:38 GMT 2024
    - Last Modified: Wed Apr 10 17:07:25 GMT 2024
    - 105 bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  5. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/FileBackedOutputStreamAndroidIncompatibleTest.java

        write(out, data, 0, 100, true);
        final File file = out.getFile();
        assertEquals(100, file.length());
        assertTrue(file.exists());
        out.close();
    
        // Make sure that finalize deletes the file
        out = null;
    
        // times out and throws RuntimeException on failure
        GcFinalization.awaitDone(
            new GcFinalization.FinalizationPredicate() {
              @Override
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Jun 08 21:20:23 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/FileBackedOutputStreamAndroidIncompatibleTest.java

        write(out, data, 0, 100, true);
        final File file = out.getFile();
        assertEquals(100, file.length());
        assertTrue(file.exists());
        out.close();
    
        // Make sure that finalize deletes the file
        out = null;
    
        // times out and throws RuntimeException on failure
        GcFinalization.awaitDone(
            new GcFinalization.FinalizationPredicate() {
              @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Jun 08 21:20:23 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  8. internal/config/cache/cache.go

    	if err != nil {
    		return
    	}
    
    	resp, err := c.clnt.Do(req)
    	if err != nil {
    		return
    	}
    	defer xhttp.DrainBody(resp.Body)
    }
    
    // Delete deletes remote cached content for object and its version.
    func (c Config) Delete(bucket, key string) {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if !c.Enable {
    		return
    	}
    
    	if c.Endpoint == "" {
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  9. 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)
  10. istioctl/pkg/tag/util.go

    }
    
    // DeleteTagWebhooks deletes the given webhooks.
    func DeleteTagWebhooks(ctx context.Context, client kubernetes.Interface, tag string) error {
    	webhooks, err := GetWebhooksWithTag(ctx, client, tag)
    	if err != nil {
    		return err
    	}
    	var result error
    	for _, wh := range webhooks {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jan 16 17:43:42 GMT 2024
    - 5.4K bytes
    - Viewed (1)
Back to top