Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 21 for deleteAll (0.04 seconds)

  1. internal/bucket/lifecycle/lifecycle.go

    func (a Action) DeleteVersioned() bool {
    	return a == DeleteVersionAction || a == DeleteRestoredVersionAction
    }
    
    // DeleteAll - Returns true if the action demands deleting all versions of an object
    func (a Action) DeleteAll() bool {
    	return a == DeleteAllVersionsAction || a == DelMarkerDeleteAllVersionsAction
    }
    
    // Delete - Returns true if action demands delete on all objects (including restored)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 03 06:45:06 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  2. cmd/metacache-bucket.go

    	for k, v := range b.cachesRoot {
    		tmp := make([]string, len(v))
    		copy(tmp, v)
    		dst2[k] = tmp
    	}
    
    	return dst, dst2
    }
    
    // deleteAll will delete all on disk data for ALL caches.
    // Deletes are performed concurrently.
    func (b *bucketMetacache) deleteAll() {
    	ctx := context.Background()
    
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return
    	}
    
    	ez, ok := objAPI.(deleteAllStorager)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. internal/bucket/lifecycle/expiration.go

    	}
    
    	if !e.DeleteMarker.set && !e.DeleteAll.set && e.IsDaysNull() && e.IsDateNull() {
    		return errXMLNotWellFormed
    	}
    
    	// Both expiration days and date are specified
    	if !e.IsDaysNull() && !e.IsDateNull() {
    		return errLifecycleInvalidExpiration
    	}
    
    	// DeleteAll set without expiration days
    	if e.DeleteAll.set && e.IsDaysNull() {
    		return errLifecycleInvalidDeleteAll
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  4. cmd/metacache-manager.go

    		v.status = scanStateError
    		m.mu.Lock()
    		m.trash[k] = v
    		m.mu.Unlock()
    	}
    }
    
    // deleteAll will delete all caches.
    func (m *metacacheManager) deleteAll() {
    	m.init.Do(m.initManager)
    	m.mu.Lock()
    	defer m.mu.Unlock()
    	for bucket, b := range m.buckets {
    		b.deleteAll()
    		delete(m.buckets, bucket)
    	}
    }
    
    // checkMetacacheState should be used if data is not updating.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Click Count (0)
  5. internal/bucket/lifecycle/evaluator_test.go

    		}
    	}
    
    	lc = Lifecycle{
    		Rules: []Rule{
    			{
    				ID:     "AllVersionsExpiration",
    				Status: "Enabled",
    				Filter: Filter{},
    				Expiration: Expiration{
    					Days: 1,
    					DeleteAll: Boolean{
    						val: true,
    						set: true,
    					},
    					set: true,
    				},
    			},
    		},
    	}
    
    	now = time.Date(2025, time.February, 12, 23, 0, 0, 0, time.UTC)
    	evaluator = NewEvaluator(lc)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 08 15:41:24 GMT 2025
    - 5K bytes
    - Click Count (0)
  6. cmd/metacache.go

    		return
    	}
    	ez, ok := objAPI.(deleteAllStorager)
    	if !ok {
    		bugLogIf(ctx, errors.New("metacache.delete: expected objAPI to be 'deleteAllStorager'"))
    		return
    	}
    	ez.deleteAll(ctx, minioMetaBucket, metacachePrefixForID(m.bucket, m.id))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 16:23:16 GMT 2024
    - 6K bytes
    - Click Count (0)
  7. cmd/erasure-multipart.go

    		if disk != nil {
    			wg.Add(1)
    			go func(disk StorageAPI) {
    				defer wg.Done()
    				er.cleanupStaleUploadsOnDisk(ctx, disk)
    			}(disk)
    		}
    	}
    	wg.Wait()
    }
    
    func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) {
    	var wg sync.WaitGroup
    	for _, disk := range er.getDisks() {
    		if disk == nil {
    			continue
    		}
    		wg.Add(1)
    		go func(disk StorageAPI) {
    			defer wg.Done()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  8. cmd/test-utils_test.go

    func ExecObjectLayerTest(t TestErrHandler, objTest objTestType) {
    	{
    		ctx, cancel := context.WithCancel(context.Background())
    		if localMetacacheMgr != nil {
    			localMetacacheMgr.deleteAll()
    		}
    
    		objLayer, fsDir, err := prepareFS(ctx)
    		if err != nil {
    			t.Fatalf("Initialization of object layer failed for single node setup: %s", err)
    		}
    		setObjectLayer(objLayer)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool.go

    		}
    	}
    
    	if err == nil {
    		// Purge the entire bucket metadata entirely.
    		z.deleteAll(context.Background(), minioMetaBucket, pathJoin(bucketMetaPrefix, bucket))
    	}
    
    	return toObjectErr(err, bucket)
    }
    
    // deleteAll will rename bucket+prefix unconditionally across all disks to
    // minioMetaTmpDeletedBucket + unique uuid,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  10. cmd/data-scanner.go

    	}
    
    	opts.Versioned = globalBucketVersioningSys.PrefixEnabled(obj.Bucket, obj.Name)
    	opts.VersionSuspended = globalBucketVersioningSys.PrefixSuspended(obj.Bucket, obj.Name)
    
    	if lcEvent.Action.DeleteAll() {
    		opts.DeletePrefix = true
    		// use prefix delete on exact object (this is an optimization to avoid fan-out calls)
    		opts.DeletePrefixObject = true
    	}
    	var (
    		dobj ObjectInfo
    		err  error
    	)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
Back to Top