Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for GetBucketInfo (0.31 sec)

  1. cmd/bucket-notification-handlers.go

    	if s3Error := checkRequestAuthType(ctx, r, policy.GetBucketNotificationAction, bucketName, ""); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	_, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	config, err := globalBucketMetadataSys.GetNotificationConfig(bucketName)
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  2. 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))
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  3. cmd/dummy-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Validate if bucket exists, before proceeding further...
    	_, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrNoSuchWebsiteConfiguration), r.URL)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 7.1K bytes
    - Viewed (0)
  4. cmd/bucket-policy-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Check if bucket exists.
    	if _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Error out if Content-Length is missing.
    	// PutBucketPolicy always needs Content-Length.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  5. cmd/bucket-replication-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    	// Check if bucket exists.
    	if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Oct 28 04:08:53 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  6. cmd/bucket-encryption-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Check if bucket exists.
    	if _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Parse bucket encryption xml
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  7. cmd/admin-bucket-handlers.go

    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.SetBucketQuotaAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	vars := mux.Vars(r)
    	bucket := pathClean(vars["bucket"])
    
    	if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	data, err := io.ReadAll(r.Body)
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  8. cmd/bucket-lifecycle-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Check if bucket exists.
    	if _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	bucketLifecycle, err := lifecycle.ParseLifecycleConfigWithID(io.LimitReader(r.Body, r.ContentLength))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 21 17:48:06 GMT 2023
    - 7K bytes
    - Viewed (0)
  9. 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.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  10. cmd/acl-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Before proceeding validate if bucket exists.
    	_, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	aclHeader := r.Header.Get(xhttp.AmzACL)
    	if aclHeader == "" {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 8.4K bytes
    - Viewed (0)
Back to top