Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewObjectReadSeekCloser (0.1 sec)

  1. internal/s3select/select.go

    	reader io.ReadCloser
    
    	// reader can be closed idempotently multiple times
    	closerOnce sync.Once
    	// Error storing reader.Close()
    	closerErr error
    }
    
    // NewObjectReadSeekCloser creates a new ObjectReadSeekCloser.
    func NewObjectReadSeekCloser(segmentReader ObjectSegmentReaderFn, actualSize int64) *ObjectReadSeekCloser {
    	return &ObjectReadSeekCloser{
    		segmentReader: segmentReader,
    		size:          actualSize,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    		return
    	}
    
    	actualSize, err := objInfo.GetActualSize()
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	objectRSC := s3select.NewObjectReadSeekCloser(
    		func(offset int64) (io.ReadCloser, error) {
    			rs := &HTTPRangeSpec{
    				IsSuffixLength: false,
    				Start:          offset,
    				End:            -1,
    			}
    			opts.NoLock = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
Back to top