Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for getObjectInfo (0.38 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  5. cmd/erasure-object_test.go

    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    	// Fetch object from store.
    	_, err = xl.GetObjectInfo(ctx, bucket, object, opts)
    	if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    		t.Errorf("Expected getObjectInfo to fail with %v, but failed with %v", toObjectErr(errErasureWriteQuorum, bucket, object), err)
    	}
    }
    
    func TestPutObjectNoQuorum(t *testing.T) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  6. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  7. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:25 UTC 2025
    - 13.3K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
Back to top