Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 21 for getObjectInfo (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/post-policy_test.go

    		}
    		// When the operation is successful, check if sending metadata is successful too
    		if rec.Code == http.StatusNoContent {
    			objInfo, err := obj.GetObjectInfo(context.Background(), bucketName, testCase.objectName+"/upload.txt", opts)
    			if err != nil {
    				t.Error("Unexpected error: ", err)
    			}
    			for k, v := range testCase.expectedHeaders {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.6K bytes
    - Viewed (0)
  6. cmd/batch-rotate.go

    	opts := ObjectOptions{
    		VersionID:        objInfo.VersionID,
    		Versioned:        versioned,
    		VersionSuspended: versionSuspended,
    		NoLock:           true,
    	}
    	obj, err := api.GetObjectInfo(ctx, r.Bucket, objInfo.Name, opts)
    	if err != nil {
    		return err
    	}
    	oi := obj.Clone()
    	var (
    		newKeyID      string
    		newKeyContext kms.Context
    	)
    	encMetadata := make(map[string]string)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  7. cmd/erasure-multipart.go

    			lkctx, err := ns.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return nil, err
    			}
    			ctx = lkctx.Context()
    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    		if err == nil && opts.CheckPrecondFn(obj) {
    			return nil, PreConditionFailed{}
    		}
    		if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  8. cmd/erasure-healing_test.go

    			t.Errorf("Expect %v but received %v", ObjectNotFound{Bucket: bucket, Object: object}, err)
    		}
    	}
    
    	// since majority of xl.meta's are not available, object should be successfully deleted.
    	_, err = objLayer.GetObjectInfo(ctx, bucket, object, ObjectOptions{})
    	if _, ok := err.(ObjectNotFound); !ok {
    		t.Errorf("Expect %v but received %v", ObjectNotFound{Bucket: bucket, Object: object}, err)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  9. cmd/object-handlers_test.go

    			t.Fatalf("%s Object: %s ObjectIndex %d PartNumber: %d: Got response status `%d` and body: %s,%v",
    				instanceType, object, oindex, partNumber, rec.Code, string(bd), err1)
    		}
    
    		oinfo, err := obj.GetObjectInfo(context.Background(), bucketName, object, ObjectOptions{})
    		if err != nil {
    			t.Fatalf("Object: %s Object Index %d: Unexpected err: %v", object, oindex, err)
    		}
    
    		rs := partNumberToRangeSpec(oinfo, partNumber)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    	}
    	var sync, replicate bool
    	for _, tgtArn := range tgtArns {
    		opts.TargetArn = tgtArn
    		replicate = rcfg.Replicate(opts)
    		// when incoming delete is removal of a delete marker(a.k.a versioned delete),
    		// GetObjectInfo returns extra information even though it returns errFileNotFound
    		if gerr != nil {
    			validReplStatus := false
    			switch oi.TargetReplicationStatus(tgtArn) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
Back to top