Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for deletedObjects (0.08 sec)

  1. cmd/bucket-handlers_test.go

    	encodedSuccessResponse0 := encodeResponse(successResponse0)
    
    	successRequest1 := encodeResponse(requestList[1])
    
    	deletedObjects = make([]DeletedObject, len(requestList[1].Objects))
    	for i := range requestList[1].Objects {
    		var vid string
    		if isDirObject(requestList[0].Objects[i].ObjectName) {
    			vid = ""
    		}
    		deletedObjects[i] = DeletedObject{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  2. cmd/api-response.go

    	}
    	return listMultipartUploadsResponse
    }
    
    // generate multi objects delete response.
    func generateMultiDeleteResponse(quiet bool, deletedObjects []DeletedObject, errs []DeleteError) DeleteObjectsResponse {
    	deleteResp := DeleteObjectsResponse{}
    	if !quiet {
    		deleteResp.DeletedObjects = deletedObjects
    	}
    	deleteResp.Errors = errs
    	return deleteResp
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    }
    
    // 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
    func (s *erasureSets) DeleteObjects(ctx context.Context, bucket string, objects []ObjectToDelete, opts ObjectOptions) ([]DeletedObject, []error) {
    	type delObj struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  4. 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)
  5. 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)
  6. 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)
  7. cmd/bucket-replication-utils.go

    }
    
    // VersionPurgeStatus returns a composite version purge status across targets
    func (d *DeletedObject) VersionPurgeStatus() VersionPurgeStatusType {
    	return d.ReplicationState.CompositeVersionPurgeStatus()
    }
    
    // DeleteMarkerReplicationStatus return composite replication status of delete marker across targets
    func (d *DeletedObject) DeleteMarkerReplicationStatus() replication.StatusType {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  8. 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)
  9. 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