Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for remoteVersionID (0.09 sec)

  1. cmd/warm-backend.go

    	Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error)
    	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)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. cmd/warm-backend-s3.go

    	res, err := s3.client.PutObject(ctx, s3.Bucket, s3.getDest(object), r, length, minio.PutObjectOptions{
    		SendContentMd5: true,
    		StorageClass:   s3.StorageClass,
    		UserMetadata:   meta,
    	})
    	return remoteVersionID(res.VersionID), s3.ToObjectError(err, object)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Jun 08 16:13:30 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  3. cmd/warm-backend-azure.go

    	if resp.VersionID != nil {
    		vid = *resp.VersionID
    	}
    	return remoteVersionID(vid), nil
    }
    
    func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	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) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. cmd/warm-backend-minio.go

    	}
    	return partSize, nil
    }
    
    func (m *warmBackendMinIO) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) {
    	partSize, err := optimalPartSize(length)
    	if err != nil {
    		return remoteVersionID(""), err
    	}
    	res, err := m.client.PutObject(ctx, m.Bucket, m.getDest(object), r, length, minio.PutObjectOptions{
    		StorageClass:         m.StorageClass,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (1)
  5. cmd/warm-backend-gcs.go

    // Currently it's a no-op.
    func (gcs *warmBackendGCS) Put(ctx context.Context, key string, data io.Reader, length int64) (remoteVersionID, error) {
    	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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. cmd/tier-sweeper.go

    func deleteObjectFromRemoteTier(ctx context.Context, objName, rvID, tierName string) error {
    	w, err := globalTierConfigMgr.getDriver(ctx, tierName)
    	if err != nil {
    		return err
    	}
    	return w.Remove(ctx, objName, remoteVersionID(rvID))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top