Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for BucketExists (0.21 sec)

  1. cmd/site-replication.go

    		for _, bucketInfo := range buckets {
    			bucket := bucketInfo.Name
    			bucketExists := bucketInfo.Deleted.IsZero() || (!bucketInfo.Created.IsZero() && bucketInfo.Created.After(bucketInfo.Deleted))
    			bms := madmin.SRBucketInfo{
    				Bucket:    bucket,
    				CreatedAt: bucketInfo.Created.UTC(),
    				DeletedAt: bucketInfo.Deleted.UTC(),
    			}
    			if !bucketExists {
    				info.Buckets[bucket] = bms
    				continue
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  2. cmd/bucket-policy-handlers_test.go

    	for i := 0; i < n; i++ {
    		go func() {
    			defer wg.Done()
    			// Sync start.
    			<-start
    			if err := obj.MakeBucket(GlobalContext, bucketName1, MakeBucketOptions{}); err != nil {
    				if _, ok := err.(BucketExists); !ok {
    					t.Logf("unexpected error: %T: %v", err, err)
    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(apiErr), r.URL)
    		return
    	}
    
    	// Proceed to creating a bucket.
    	if err := objectAPI.MakeBucket(ctx, bucket, opts); err != nil {
    		if _, ok := err.(BucketExists); ok {
    			// Though bucket exists locally, we send the site-replication
    			// hook to ensure all sites have this bucket. If the hook
    			// succeeds, the client will still receive a bucket exists
    			// message.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  4. cmd/api-errors.go

    	case BucketAlreadyOwnedByYou:
    		apiErr = ErrBucketAlreadyOwnedByYou
    	case BucketNotEmpty:
    		apiErr = ErrBucketNotEmpty
    	case BucketAlreadyExists:
    		apiErr = ErrBucketAlreadyExists
    	case BucketExists:
    		apiErr = ErrBucketAlreadyOwnedByYou
    	case ObjectNotFound:
    		apiErr = ErrNoSuchKey
    	case MethodNotAllowed:
    		apiErr = ErrMethodNotAllowed
    	case ObjectLocked:
    		apiErr = ErrObjectLocked
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    			if err != nil {
    				return err
    			}
    
    			ctx = lkctx.Context()
    			defer lk.Unlock(lkctx)
    		}
    	}
    
    	if err := z.s3Peer.MakeBucket(ctx, bucket, opts); err != nil {
    		if _, ok := err.(BucketExists); !ok {
    			// Delete created buckets, ignoring errors.
    			z.DeleteBucket(context.Background(), bucket, DeleteBucketOptions{
    				NoLock:     true,
    				NoRecreate: true,
    			})
    		}
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    		if clnt == nil {
    			return sameTarget, toAPIError(ctx, BucketRemoteTargetNotFound{Bucket: bucket})
    		}
    		if opts.CheckRemoteBucket { // validate remote bucket
    			found, err := clnt.BucketExists(ctx, arn.Bucket)
    			if err != nil {
    				return sameTarget, errorCodes.ToAPIErrWithErr(ErrRemoteDestinationNotFoundError, err)
    			}
    			if !found {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top