- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 21 for deleteAll (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)