- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for deleteAll (0.25 sec)
-
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.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (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)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (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)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.6K bytes - Viewed (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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 21 20:28:34 GMT 2024 - 6.6K bytes - Viewed (1) -
istioctl/pkg/waypoint/waypoint.go
istioctl x waypoint delete --all --namespace default`, Args: func(cmd *cobra.Command, args []string) error { if deleteAll && len(args) > 0 { return fmt.Errorf("cannot specify waypoint names when deleting all waypoints") } if !deleteAll && len(args) == 0 { return fmt.Errorf("must either specify a waypoint name or delete all using --all") } return nil },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (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,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
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)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 17.5K bytes - Viewed (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))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0) -
cmd/erasure-multipart.go
wg.Add(1) go func(disk StorageAPI) { defer wg.Done() er.cleanupStaleUploadsOnDisk(ctx, disk, expiry) }(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()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/data-scanner.go
var action lifecycle.Action action, size = i.applyLifecycle(ctx, o, oi) done() // Note: objDeleted is true if and only if action == // lifecycle.DeleteAllVersionsAction if action.DeleteAll() { return true, 0 } // For instance, an applied lifecycle means we remove/transitioned an object // from the current deployment, which means we don't have to call healing
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0)