Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ReadFileStream (0.07 sec)

  1. cmd/naughty-disk_test.go

    		return 0, err
    	}
    	return d.disk.ReadFile(ctx, volume, path, offset, buf, verifier)
    }
    
    func (d *naughtyDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	if err := d.calcError(); err != nil {
    		return nil, err
    	}
    	return d.disk.ReadFileStream(ctx, volume, path, offset, length)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    		Volume:   volume,
    		FilePath: path,
    	})
    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    
    	return *gridBytes, nil
    }
    
    // ReadFileStream - returns a reader for the requested file.
    func (client *storageRESTClient) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. cmd/erasure-encode_test.go

    func (a badDisk) String() string {
    	return "bad-disk"
    }
    
    func (a badDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	return errFaultyDisk
    }
    
    func (a badDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	return nil, errFaultyDisk
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    	if err != nil {
    		return err
    	}
    	defer done(size, &err)
    
    	return p.storage.CreateFile(ctx, origvolume, volume, path, size, io.NopCloser(reader))
    }
    
    func (p *xlStorageDiskIDCheck) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadFileStream, volume, path)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    		return
    	}
    	length, err := strconv.ParseInt(r.Form.Get(storageRESTLength), 10, 64)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	rc, err := s.getStorage().ReadFileStream(r.Context(), volume, filePath, offset, length)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	defer rc.Close()
    
    	_, err = xioutil.Copy(w, rc)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
Back to top