Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for abortMultipartUpload (0.19 sec)

  1. cmd/object-multipart-handlers.go

    		return
    	}
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    	abortMultipartUpload := objectAPI.AbortMultipartUpload
    
    	if s3Error := checkRequestAuthType(ctx, r, policy.AbortMultipartUploadAction, bucket, object); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  2. helm/minio/values.yaml

    ## example.
    # - name: writeexamplepolicy
    #   statements:
    #     - effect: Allow  # this is the default
    #       resources:
    #         - 'arn:aws:s3:::example*/*'
    #       actions:
    #         - "s3:AbortMultipartUpload"
    #         - "s3:GetObject"
    #         - "s3:DeleteObject"
    #         - "s3:PutObject"
    #         - "s3:ListMultipartUploadParts"
    #     - resources:
    #         - 'arn:aws:s3:::example*'
    #       actions:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 15:48:31 UTC 2024
    - 18.8K bytes
    - Viewed (1)
  3. cmd/object-api-multipart_test.go

    	}
    
    	err = obj.AbortMultipartUpload(context.Background(), bucket, "\\", res.UploadID, opts)
    	if err != nil {
    		switch err.(type) {
    		case InvalidUploadID:
    			t.Fatalf("%s: New Multipart upload failed to create uuid file.", instanceType)
    		default:
    			t.Fatal(err.Error())
    		}
    	}
    }
    
    // Wrapper for calling AbortMultipartUpload tests for both Erasure multiple disks and single node setup.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    // would be removed from the system, rollback is not possible on this
    // operation.
    func (er erasureObjects) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) (err error) {
    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "AbortMultipartUpload", object, &er)
    	}
    
    	// Validates if upload ID exists.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    }
    
    // Aborts an in-progress multipart operation on hashedSet based on the object name.
    func (s *erasureSets) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) error {
    	set := s.getHashedSet(object)
    	return set.AbortMultipartUpload(ctx, bucket, object, uploadID, opts)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  6. cmd/object-api-interface.go

    	ListObjectParts(ctx context.Context, bucket, object, uploadID string, partNumberMarker int, maxParts int, opts ObjectOptions) (result ListPartsInfo, err error)
    	AbortMultipartUpload(ctx context.Context, bucket, object, uploadID 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)
  7. cmd/api-router.go

    			Queries("uploadId", "{uploadId:.*}")
    		// NewMultipartUpload
    		router.Methods(http.MethodPost).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.NewMultipartUploadHandler)).
    			Queries("uploads", "")
    		// AbortMultipartUpload
    		router.Methods(http.MethodDelete).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.AbortMultipartUploadHandler)).
    			Queries("uploadId", "{uploadId:.*}")
    		// GetObjectACL - this is a dummy call.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. cmd/object_api_suite_test.go

    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    		if calcPartInfo.ETag != expectedETaghex {
    			t.Errorf("Md5 Mismatch")
    		}
    		parts[i] = expectedETaghex
    	}
    	err = obj.AbortMultipartUpload(context.Background(), "bucket", "key", uploadID, ObjectOptions{})
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    	}
    	ctx = lkctx.Context()
    	defer lk.Unlock(lkctx)
    
    	if z.SinglePool() {
    		return z.serverPools[0].AbortMultipartUpload(ctx, bucket, object, uploadID, opts)
    	}
    
    	for idx, pool := range z.serverPools {
    		if z.IsSuspended(idx) {
    			continue
    		}
    		err := pool.AbortMultipartUpload(ctx, bucket, object, uploadID, opts)
    		if err == nil {
    			return nil
    		}
    		if _, ok := err.(InvalidUploadID); ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-rebalance.go

    			NoAuditLog:   true,
    			DataMovement: true,
    			SrcPoolIdx:   poolIdx,
    		})
    		if err != nil {
    			return fmt.Errorf("rebalanceObject: NewMultipartUpload() %w", err)
    		}
    		defer z.AbortMultipartUpload(ctx, bucket, oi.Name, res.UploadID, ObjectOptions{NoAuditLog: true})
    
    		parts := make([]CompletePart, len(oi.Parts))
    		for i, part := range oi.Parts {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
Back to top