- Sort Score
- Num 10 results
- Language All
Results 51 - 60 of 75 for deleteOption (0.06 seconds)
-
cmd/storage-datatypes_gen_test.go
} } func BenchmarkMarshalMsgDeleteOptions(b *testing.B) { v := DeleteOptions{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgDeleteOptions(b *testing.B) { v := DeleteOptions{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts))) b.ReportAllocs()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 73.9K bytes - Click Count (0) -
cmd/erasure-healing-common_test.go
// and check if that disk // appears in outDatedDisks. tamperedIndex = index dErr := erasureDisks[index].Delete(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{ Recursive: false, Immediate: false, }) if dErr != nil { t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr) } break }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 22.4K bytes - Click Count (0) -
cmd/erasure-object.go
for index := range disks { g.Go(func() error { if disks[index] == nil { return errDiskNotFound } return disks[index].DeleteVersion(ctx, bucket, object, fi, false, DeleteOptions{}) }, index) } for index, err := range g.Wait() { var errStr string if err != nil { errStr = err.Error() } else { errStr = "<nil>" }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
cmd/erasure-encode_test.go
for b.Loop() { writers := make([]io.Writer, len(disks)) for i, disk := range disks { if disk == OfflineDisk { continue } disk.Delete(context.Background(), "testbucket", "object", DeleteOptions{ Recursive: false, Immediate: false, }) writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize()) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.8K bytes - Click Count (0) -
cmd/storage-rest_test.go
// file not found not returned {"foo", "yourobject", false}, } for i, testCase := range testCases { err := storage.Delete(t.Context(), testCase.volumeName, testCase.objectName, DeleteOptions{ Recursive: false, Immediate: false, }) expectErr := (err != nil) if expectErr != testCase.expectErr { t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 11.4K bytes - Click Count (0) -
cmd/erasure-healing.go
// - Remove any remaining parts from outdated disks from before transition. if partsMetadata[i].IsRemote() { rmDataDir := partsMetadata[i].DataDir disk.Delete(ctx, bucket, pathJoin(encodeDirObject(object), rmDataDir), DeleteOptions{ Immediate: true, Recursive: true, }) } for i, v := range result.Before.Drives { if v.Endpoint == disk.Endpoint().String() { result.After.Drives[i].State = madmin.DriveStateOk
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
cmd/background-newdisks-heal-ops.go
} // delete the tracker on disk. func (h *healingTracker) delete(ctx context.Context) error { return h.disk.Delete(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, healingTrackerFilename), DeleteOptions{ Recursive: false, Immediate: false, }, ) } func (h *healingTracker) isHealed(bucket string) bool { h.mu.RLock() defer h.mu.RUnlock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 16.5K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.5.md
- [alpha] Cluster federation: Added support for DeleteOptions.OrphanDependents for federation resources. ([docs](http://kubernetes.io/docs/user-guide/federation/#cascading-deletion)) ([kubernetes/features#99](https://github.com/kubernetes/enhancements/issues/99))
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Dec 24 02:28:26 GMT 2020 - 136.4K bytes - Click Count (0) -
cmd/erasure-object_test.go
} for _, disk := range xl.getDisks() { files, _ := disk.ListDir(ctx, "", bucket, object, -1) for _, file := range files { if file != "xl.meta" { disk.Delete(ctx, bucket, pathJoin(object, file), DeleteOptions{ Recursive: true, Immediate: false, }) } } } gr, err := xl.GetObjectNInfo(ctx, bucket, object, nil, nil, opts) if err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 38.3K bytes - Click Count (0) -
cmd/xl-storage.go
func (s *xlStorage) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) { if HasSuffix(path, SlashSeparator) { return s.Delete(ctx, volume, path, DeleteOptions{ Recursive: false, Immediate: false, }) } volumeDir, err := s.getVolDir(volume) if err != nil { return err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0)