Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ReadCloser (0.06 sec)

  1. cmd/warm-backend.go

    	PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error)
    	Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error)
    	Remove(ctx context.Context, object string, rv remoteVersionID) error
    	InUse(ctx context.Context) (bool, error)
    }
    
    const probeObject = "probeobject"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. cmd/warm-backend-s3.go

    	return s3.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func (s3 *warmBackendS3) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) {
    	gopts := minio.GetObjectOptions{}
    
    	if rv != "" {
    		gopts.VersionID = string(rv)
    	}
    	if opts.startOffset >= 0 && opts.length > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. cmd/warm-backend-gcs.go

    	return gcs.PutWithMeta(ctx, key, data, length, map[string]string{})
    }
    
    func (gcs *warmBackendGCS) Get(ctx context.Context, key string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    	// GCS storage decompresses a gzipped object by default and returns the data.
    	// Refer to https://cloud.google.com/storage/docs/transcoding#decompressive_transcoding
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. cmd/warm-backend-azure.go

    	return az.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func (az *warmBackendAzure) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    	if opts.startOffset < 0 {
    		return nil, InvalidRange{}
    	}
    	resp, err := az.clnt.DownloadStream(ctx, az.Bucket, az.getDest(object), &azblob.DownloadStreamOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadFileStream, volume, path)
    	if err != nil {
    		return nil, err
    	}
    	defer done(length, &err)
    
    	return xioutil.WithDeadline[io.ReadCloser](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result io.ReadCloser, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	io.Reader
    	io.Closer
    }
    
    // ReadFileStream - Returns the read stream of the file.
    func (s *xlStorage) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	if offset < 0 {
    		return nil, errInvalidArgument
    	}
    
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    		return nil, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top