Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 298 for deletes (0.22 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. internal/bucket/replication/rule.go

    	errInvalidDeleteMarkerReplicationStatus   = Errorf("Delete marker replication status is invalid")
    	errDestinationSourceIdentical             = Errorf("Destination bucket cannot be the same as the source bucket.")
    	errDeleteReplicationMissing               = Errorf("Delete replication must be specified")
    	errInvalidDeleteReplicationStatus         = Errorf("Delete replication is either enable|disable")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jan 24 23:22:20 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  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. 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)
  7. 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)
  8. cmd/notification.go

    func (sys *NotificationSys) DeleteBucketMetadata(ctx context.Context, bucketName string) {
    	globalReplicationStats.Delete(bucketName)
    	globalBucketMetadataSys.Remove(bucketName)
    	globalBucketTargetSys.Delete(bucketName)
    	globalEventNotifier.RemoveNotification(bucketName)
    	globalBucketConnStats.delete(bucketName)
    	globalBucketHTTPStats.delete(bucketName)
    	if localMetacacheMgr != nil {
    		localMetacacheMgr.deleteBucketCache(bucketName)
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  9. 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)
  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 01 22:53:12 GMT 2024
    - Last Modified: Tue Jan 16 17:43:42 GMT 2024
    - 5.4K bytes
    - Viewed (1)
Back to top