Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for deleteObject (0.1 sec)

  1. cmd/erasure-server-pool.go

    	return objInfo, err
    }
    
    func (z *erasureServerPools) DeleteObjects(ctx context.Context, bucket string, objects []ObjectToDelete, opts ObjectOptions) ([]DeletedObject, []error) {
    	derrs := make([]error, len(objects))
    	dobjects := make([]DeletedObject, len(objects))
    	objSets := set.NewStringSet()
    	for i := range derrs {
    		objects[i].ObjectName = encodeDirObject(objects[i].ObjectName)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	if !opts.NoAuditLog {
    		for _, obj := range objects {
    			auditObjectErasureSet(ctx, "DeleteObjects", obj.ObjectName, &er)
    		}
    	}
    
    	errs := make([]error, len(objects))
    	dobjects := make([]DeletedObject, len(objects))
    	writeQuorums := make([]int, len(objects))
    
    	storageDisks := er.getDisks()
    
    	for i := range objects {
    		// Assume (N/2 + 1) quorums for all objects
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  3. cmd/object-api-listobjects_test.go

    			UserDefined: object.meta,
    		})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err.Error())
    		}
    		if object.addDeleteMarker {
    			oi, err := obj.DeleteObject(context.Background(), object.parentBucket, object.name, ObjectOptions{
    				Versioned: globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name),
    			})
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 76.1K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    	}
    
    	versionID := srcObjInfo.VersionID
    	if r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3 {
    		versionID = ""
    	}
    	if srcObjInfo.DeleteMarker {
    		_, err := api.DeleteObject(ctx, tgtBucket, tgtObject, ObjectOptions{
    			VersionID: versionID,
    			// Since we are preserving a delete marker, we have to make sure this is always true.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    		case "PutObject":
    			// Register PutObject handler.
    			bucket.Methods(http.MethodPut).Path("/{object:.+}").HandlerFunc(api.PutObjectHandler)
    		case "DeleteObject":
    			// Register Delete Object handler.
    			bucket.Methods(http.MethodDelete).Path("/{object:.+}").HandlerFunc(api.DeleteObjectHandler)
    		case "CopyObject":
    			// Register Copy Object  handler.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  6. cmd/bucket-handlers.go

    	// Ignore errors here to preserve the S3 error behavior of GetBucketInfo()
    	checkRequestAuthType(ctx, r, policy.DeleteObjectAction, bucket, "")
    
    	deleteObjectsFn := objectAPI.DeleteObjects
    
    	// Return Malformed XML as S3 spec if the number of objects is empty
    	if len(deleteObjectsReq.Objects) == 0 || len(deleteObjectsReq.Objects) > maxDeleteList {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
Back to top