Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for DeleteObjects (0.15 sec)

  1. cmd/admin-handlers_test.go

    func TestTopLockEntries(t *testing.T) {
    	locksHeld := make(map[string][]lockRequesterInfo)
    	var owners []string
    	for i := 0; i < 4; i++ {
    		owners = append(owners, fmt.Sprintf("node-%d", i))
    	}
    
    	// Simulate DeleteObjects of 10 objects in a single request. i.e same lock
    	// request UID, but 10 different resource names associated with it.
    	var lris []lockRequesterInfo
    	uuid := mustGetUUID()
    	for i := 0; i < 10; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    	return set.DeleteObject(ctx, bucket, object, opts)
    }
    
    // DeleteObjects - bulk delete of objects
    // Bulk delete is only possible within one set. For that purpose
    // objects are group by set first, and then bulk delete is invoked
    // for each set, the error response of each delete will be returned
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  3. cmd/batch-expire.go

    	allErrs := make([]error, 0, len(objsToDel))
    
    	for {
    		count := len(objsToDel)
    		if count == 0 {
    			break
    		}
    		if count > maxDeleteList {
    			count = maxDeleteList
    		}
    		_, errs := api.DeleteObjects(ctx, r.Bucket, objsToDel[:count], opts)
    		allErrs = append(allErrs, errs...)
    		// Next batch of deletion
    		objsToDel = objsToDel[count:]
    	}
    
    	return allErrs
    }
    
    const (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  4. cmd/object-handlers-common.go

    			remaining = toDel[maxDeleteList:]
    			toDel = toDel[:maxDeleteList]
    		} else {
    			remaining = nil
    		}
    		vc, _ := globalBucketVersioningSys.Get(bucket)
    		deletedObjs, errs := o.DeleteObjects(ctx, bucket, toDel, ObjectOptions{
    			PrefixEnabledFn:  vc.PrefixEnabled,
    			VersionSuspended: vc.Suspended(),
    		})
    
    		for i, dobj := range deletedObjs {
    			oi := ObjectInfo{
    				Bucket:    bucket,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  5. cmd/object-api-interface.go

    	DeleteObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error)
    	DeleteObjects(ctx context.Context, bucket string, objects []ObjectToDelete, opts ObjectOptions) ([]DeletedObject, []error)
    	TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  6. cmd/erasure-object_test.go

    			},
    		}
    
    	}
    	names = append(names, ObjectToDelete{
    		ObjectV: ObjectV{
    			ObjectName: "dir/obj1",
    			VersionID:  mustGetUUID(), // add a non-existent UUID.
    		},
    	})
    
    	_, delErrs := obj.DeleteObjects(ctx, bucketName, names, ObjectOptions{
    		Versioned: true,
    	})
    	for i := range delErrs {
    		if delErrs[i] != nil {
    			t.Errorf("Failed to remove object `%v` with the error: `%v`", names[i], delErrs[i])
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top