Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for GetObjectNInfo (0.18 sec)

  1. cmd/erasure-object_test.go

    			if file != "xl.meta" {
    				disk.Delete(ctx, bucket, pathJoin(object, file), DeleteOptions{
    					Recursive: true,
    					Immediate: false,
    				})
    			}
    		}
    	}
    
    	gr, err := xl.GetObjectNInfo(ctx, bucket, object, nil, nil, opts)
    	if err != nil {
    		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer lock.RUnlock(lkctx)
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    	gopts := opts
    	gopts.NoLock = true // We already have a lock, we can live with it.
    	objInfo, err := getObjectInfo(ctx, bucket, object, gopts)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/object-multipart-handlers.go

    	}
    
    	dstOpts, err = copyDstOpts(ctx, r, dstBucket, dstObject, nil)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    	// Get request range.
    	var rs *HTTPRangeSpec
    	var parseRangeErr error
    	if rangeHeader := r.Header.Get(xhttp.AmzCopySourceRange); rangeHeader != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    		return toObjectErr(err, bucket)
    	}
    
    	globalBucketMetadataSys.Set(bucket, meta)
    
    	// Success.
    	return nil
    }
    
    func (z *erasureServerPools) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if err = checkGetObjArgs(ctx, bucket, object); err != nil {
    		return nil, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    					// GetObjectReader.Close is called by rebalanceObject
    					stopFn := globalRebalanceMetrics.log(rebalanceMetricRebalanceObject, poolIdx, bucket, version.Name, version.VersionID)
    					gr, err := set.GetObjectNInfo(ctx,
    						bucket,
    						encodeDirObject(version.Name),
    						nil,
    						http.Header{},
    						ObjectOptions{
    							VersionID:    versionID,
    							NoDecryption: true,
    							NoLock:       true,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    	}
    
    	return fi.ToObjectInfo(srcBucket, srcObject, srcOpts.Versioned || srcOpts.VersionSuspended), nil
    }
    
    // GetObjectNInfo - returns object info and an object
    // Read(Closer). When err != nil, the returned reader is always nil.
    func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if !opts.NoAuditLog {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  7. cmd/object-api-interface.go

    	// Object operations.
    
    	// GetObjectNInfo returns a GetObjectReader that satisfies the
    	// ReadCloser interface. The Close method runs any cleanup
    	// functions, so it must always be called after reading till EOF
    	//
    	// IMPORTANTLY, when implementations return err != nil, this
    	// function MUST NOT return a non-nil ReadCloser.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    							stopFn(err)
    							failure = true
    							decomLogIf(ctx, err)
    							continue
    						}
    						stopFn(nil)
    						failure = false
    						break
    					}
    					gr, err := set.GetObjectNInfo(ctx,
    						bi.Name,
    						encodeDirObject(version.Name),
    						nil,
    						http.Header{},
    						ObjectOptions{
    							VersionID:    versionID,
    							NoDecryption: true,
    							NoLock:       true,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  9. cmd/bucket-replication.go

    		})
    		return
    	}
    
    	versioned := globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	versionSuspended := globalBucketVersioningSys.PrefixSuspended(bucket, object)
    
    	gr, err := objectAPI.GetObjectNInfo(ctx, bucket, object, nil, http.Header{}, ObjectOptions{
    		VersionID:          ri.VersionID,
    		Versioned:          versioned,
    		VersionSuspended:   versionSuspended,
    		ReplicationRequest: true,
    	})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  10. cmd/config-common.go

    )
    
    var errConfigNotFound = errors.New("config file not found")
    
    func readConfigWithMetadata(ctx context.Context, store objectIO, configFile string, opts ObjectOptions) ([]byte, ObjectInfo, error) {
    	r, err := store.GetObjectNInfo(ctx, minioMetaBucket, configFile, nil, http.Header{}, opts)
    	if err != nil {
    		if isErrObjectNotFound(err) {
    			return nil, ObjectInfo{}, errConfigNotFound
    		}
    
    		return nil, ObjectInfo{}, err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 3.1K bytes
    - Viewed (0)
Back to top