Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for getObjectInfo (0.12 sec)

  1. cmd/s3-zip-handlers.go

    		return
    	}
    
    	opts, err := getOpts(ctx, r, bucket, zipPath)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	getObjectInfo := objectAPI.GetObjectInfo
    
    	// Check for auth type to return S3 compatible error.
    	// type to return the correct error (NoSuchKey vs AccessDenied)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    				BucketName:      bucket,
    				ConditionValues: getConditionValues(r, "", auth.AnonymousCredentials),
    				IsOwner:         false,
    			}) {
    				getObjectInfo := objectAPI.GetObjectInfo
    
    				_, err = getObjectInfo(ctx, bucket, object, opts)
    				if toAPIError(ctx, err).Code == "NoSuchKey" {
    					s3Error = ErrNoSuchKey
    				}
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    type CheckPreconditionFn func(o ObjectInfo) bool
    
    // EvalMetadataFn validates input objInfo and GetObjectInfo error and returns an updated metadata and replication decision if any
    type EvalMetadataFn func(o *ObjectInfo, gerr error) (ReplicateDecision, error)
    
    // EvalRetentionBypassFn validates input objInfo and GetObjectInfo error and returns an error if retention bypass is not allowed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  4. cmd/object_api_suite_test.go

    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    		if !bytes.Equal(byteBuffer.Bytes(), value) {
    			t.Errorf("%s: Mismatch of GetObject data with the expected one.", instanceType)
    		}
    
    		objInfo, err := obj.GetObjectInfo(context.Background(), "bucket", key, opts)
    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    		if objInfo.Size != int64(len(value)) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  5. cmd/acl-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Before proceeding validate if object exists.
    	_, err = objAPI.GetObjectInfo(ctx, bucket, object, ObjectOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	aclHeader := r.Header.Get(xhttp.AmzACL)
    	if aclHeader == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    	} // End of read all parts loop.
    	// Return success.
    	return nil
    }
    
    // GetObjectInfo - reads object metadata and replies back ObjectInfo.
    func (er erasureObjects) GetObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (info ObjectInfo, err error) {
    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetObjectInfo", object, &er)
    	}
    
    	if !opts.NoLock {
    		// Lock the object before reading.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	holdPerms := isPutActionAllowed(ctx, getRequestAuthType(r), bucket, object, r, policy.PutObjectLegalHoldAction)
    
    	getObjectInfo := objectAPI.GetObjectInfo
    
    	retentionMode, retentionDate, legalHold, s3Err := checkPutObjectLockAllowed(ctx, r, bucket, object, getObjectInfo, retPerms, holdPerms)
    	if s3Err == ErrNone && retentionMode.Valid() {
    		metadata[strings.ToLower(xhttp.AmzObjectLockMode)] = string(retentionMode)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    				for _, prefix := range li.Prefixes {
    					objInfo, _ := z.GetObjectInfo(ctx, bucket, pathJoin(prefix, "_SUCCESS"), ObjectOptions{NoLock: true})
    					if objInfo.IsLatest && objInfo.DeleteMarker {
    						continue
    					}
    					prefixes = append(prefixes, prefix)
    				}
    				if len(prefixes) > 0 {
    					objInfo, _ := z.GetObjectInfo(ctx, bucket, pathJoin(opts.Prefix, "_SUCCESS"), ObjectOptions{NoLock: true})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  9. cmd/bucket-object-lock.go

    func enforceRetentionBypassForDelete(ctx context.Context, r *http.Request, bucket string, object ObjectToDelete, oi ObjectInfo, gerr error) error {
    	if gerr != nil { // error from GetObjectInfo
    		if _, ok := gerr.(MethodNotAllowed); ok {
    			// This happens usually for a delete marker
    			if oi.DeleteMarker || !oi.VersionPurgeStatus.Empty() {
    				// Delete marker should be present and valid.
    				return nil
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	return set.PutObject(ctx, bucket, object, data, opts)
    }
    
    // GetObjectInfo - reads object metadata from the hashedSet based on the object name.
    func (s *erasureSets) GetObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	set := s.getHashedSet(object)
    	return set.GetObjectInfo(ctx, bucket, object, opts)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top