Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewGetObjectReader (0.94 sec)

  1. 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)
  2. 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)
  3. 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