Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewGetObjectReader (0.61 sec)

  1. cmd/object-api-utils.go

    // NewGetObjectReader creates a new GetObjectReader. The cleanUpFns
    // are called on Close() in FIFO order as passed in ObjReadFn(). NOTE: It is
    // assumed that clean up functions do not panic (otherwise, they may
    // not all run!).
    func NewGetObjectReader(rs *HTTPRangeSpec, oi ObjectInfo, opts ObjectOptions, h http.Header) (
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    	tgtClient, err := globalTierConfigMgr.getDriver(ctx, oi.TransitionedObject.Tier)
    	if err != nil {
    		return nil, fmt.Errorf("transition storage class not configured: %w", err)
    	}
    
    	fn, off, length, err := NewGetObjectReader(rs, oi, opts, h)
    	if err != nil {
    		return nil, ErrorRespToObjectError(err, bucket, object)
    	}
    	gopts := WarmBackendGetOpts{}
    
    	// get correct offsets for object
    	if off >= 0 && length >= 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    		if err != nil {
    			return nil, err
    		}
    		unlockOnDefer = false
    		return gr.WithCleanupFuncs(nsUnlocker), nil
    	}
    
    	fn, off, length, err := NewGetObjectReader(rs, objInfo, opts, h)
    	if err != nil {
    		return nil, err
    	}
    
    	if unlockOnDefer {
    		unlockOnDefer = fi.InlineData() || len(fi.Data) > 0
    	}
    
    	pr, pw := xioutil.WaitPipe()
    	go func() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	tgt, oi, proxy := proxyHeadToRepTarget(ctx, bucket, object, rs, opts, proxyTargets)
    	if !proxy.Proxy {
    		return nil, proxy, nil
    	}
    	fn, _, _, err := NewGetObjectReader(nil, oi, opts, h)
    	if err != nil {
    		return nil, proxy, err
    	}
    	gopts := minio.GetObjectOptions{
    		VersionID:            opts.VersionID,
    		ServerSideEncryption: opts.ServerSideEncryption,
    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