Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for getBucketInfo (0.17 sec)

  1. cmd/peer-s3-client.go

    	}
    
    	sort.Slice(result, func(i, j int) bool {
    		return result[i].Name < result[j].Name
    	})
    
    	return result, nil
    }
    
    // GetBucketInfo returns bucket stat info about bucket on disk across all peers
    func (sys *S3PeerSys) GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (binfo BucketInfo, err error) {
    	g := errgroup.WithNErrs(len(sys.peerClients))
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	getBucketInfo := objectAPI.GetBucketInfo
    
    	if _, err := getBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Generate response.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	Force      bool             // Force deletion
    	SRDeleteOp SRBucketDeleteOp // only when site replication is enabled
    }
    
    // BucketOptions provides options for ListBuckets and GetBucketInfo call.
    type BucketOptions struct {
    	Deleted    bool // true only when site replication is enabled
    	Cached     bool // true only when we are requesting a cached response instead of hitting the disk for example ListBuckets() call.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  4. cmd/bucket-metadata-sys.go

    // Only a shallow copy is returned, so referenced data should not be modified,
    // but can be replaced atomically.
    //
    // This function should only be used with
    // - GetBucketInfo
    // - ListBuckets
    // For all other bucket specific metadata, use the relevant
    // calls implemented specifically for each of those features.
    func (sys *BucketMetadataSys) Get(bucket string) (BucketMetadata, error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    		Bucket:   bucket,
    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    // GetBucketInfo - returns bucket info from one of the erasure coded serverPools.
    func (z *erasureServerPools) GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error) {
    	bucketInfo, err = z.s3Peer.GetBucketInfo(ctx, bucket, opts)
    	if err != nil {
    		return bucketInfo, toObjectErr(err, bucket)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  6. cmd/batch-rotate.go

    	if r == nil {
    		return nil
    	}
    
    	if r.APIVersion != batchKeyRotateAPIVersion {
    		return errInvalidArgument
    	}
    
    	if r.Bucket == "" {
    		return errInvalidArgument
    	}
    
    	if _, err := o.GetBucketInfo(ctx, r.Bucket, BucketOptions{}); err != nil {
    		if isErrBucketNotFound(err) {
    			return batchKeyRotationJobError{
    				Code:           "NoSuchSourceBucket",
    				Description:    "The specified source bucket does not exist",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    	}
    
    	var isRemoteToLocal bool
    	localBkt := r.Source.Bucket
    	if r.Source.Endpoint != "" {
    		localBkt = r.Target.Bucket
    		isRemoteToLocal = true
    	}
    	info, err := o.GetBucketInfo(ctx, localBkt, BucketOptions{})
    	if err != nil {
    		if isErrBucketNotFound(err) {
    			return batchReplicationJobError{
    				Code:           "NoSuchSourceBucket",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  8. cmd/bucket-lifecycle.go

    	}
    	if r.Days == 0 && r.Type != SelectRestoreRequest {
    		return fmt.Errorf("restoration days should be at least 1")
    	}
    	// Check if bucket exists.
    	if !r.OutputLocation.IsEmpty() {
    		if _, err := objAPI.GetBucketInfo(ctx, r.OutputLocation.S3.BucketName, BucketOptions{}); err != nil {
    			return err
    		}
    		if r.OutputLocation.S3.Prefix == "" {
    			return fmt.Errorf("Prefix is a required parameter in OutputLocation")
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  9. cmd/object-handlers.go

    func isRemoteCallRequired(ctx context.Context, bucket string, objAPI ObjectLayer) bool {
    	if globalDNSConfig == nil {
    		return false
    	}
    	if globalBucketFederation {
    		_, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{})
    		return err == toObjectErr(errVolumeNotFound, bucket)
    	}
    	return false
    }
    
    // CopyObjectHandler - Copy Object
    // ----------
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  10. cmd/site-replication.go

    	if opts.Buckets || opts.Entity == madmin.SRBucketEntity {
    		var (
    			buckets []BucketInfo
    			err     error
    		)
    		if opts.Entity == madmin.SRBucketEntity {
    			bi, err := objAPI.GetBucketInfo(ctx, opts.EntityValue, BucketOptions{Deleted: opts.ShowDeleted})
    			if err != nil {
    				if isErrBucketNotFound(err) {
    					return info, nil
    				}
    				return info, errSRBackendIssue(err)
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
Back to top