Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getTransitionedObjectReader (0.21 sec)

  1. cmd/bucket-lifecycle.go

    		} else {
    			op.Error = err.Error()
    			globalTierMetrics.logFailure(tier)
    		}
    
    		logger.GetReqInfo(ctx).AppendTags("tierStats", op)
    	}
    }
    
    // getTransitionedObjectReader returns a reader from the transitioned tier.
    func getTransitionedObjectReader(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, oi ObjectInfo, opts ObjectOptions) (gr *GetObjectReader, err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	if crypto.SSEC.IsEncrypted(objInfo.UserDefined) && opts.ReplicationRequest {
    		opts.NoDecryption = true
    	}
    
    	if objInfo.IsRemote() {
    		gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, h, objInfo, opts)
    		if err != nil {
    			return nil, err
    		}
    		unlockOnDefer = false
    		return gr.WithCleanupFuncs(nsUnlocker), nil
    	}
    
    	if objInfo.Size == 0 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  3. cmd/object-handlers.go

    				func(offset int64) (io.ReadCloser, error) {
    					rs := &HTTPRangeSpec{
    						IsSuffixLength: false,
    						Start:          offset,
    						End:            -1,
    					}
    					return getTransitionedObjectReader(rctx, bucket, object, rs, r.Header,
    						objInfo, ObjectOptions{VersionID: objInfo.VersionID})
    				},
    				actualSize,
    			)
    			defer objectRSC.Close()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 125K bytes
    - Viewed (0)
Back to top