Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for MakeBucket (0.06 sec)

  1. cmd/object_api_suite_test.go

    // Tests validate that recreation of the bucket fails.
    func testBucketRecreateFails(obj ObjectLayer, instanceType string, t TestErrHandler) {
    	err := obj.MakeBucket(context.Background(), "string", MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	err = obj.MakeBucket(context.Background(), "string", MakeBucketOptions{})
    	if err == nil {
    		t.Fatalf("%s: Expected error but found nil.", instanceType)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    	}, nil
    }
    
    // MakeBucket creates bucket across all peers
    func (sys *S3PeerSys) MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error {
    	g := errgroup.WithNErrs(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		g.Go(func() error {
    			if client == nil {
    				return errPeerOffline
    			}
    			return client.MakeBucket(ctx, bucket, opts)
    		}, idx)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  3. cmd/benchmark-utils_test.go

    )
    
    // Benchmark utility functions for ObjectLayer.PutObject().
    // Creates Object layer setup ( MakeBucket ) and then runs the PutObject benchmark.
    func runPutObjectBenchmark(b *testing.B, obj ObjectLayer, objSize int) {
    	var err error
    	// obtains random bucket name.
    	bucket := getRandomBucketName()
    	// create bucket.
    	err = obj.MakeBucket(b.Context(), bucket, MakeBucketOptions{})
    	if err != nil {
    		b.Fatal(err)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users_test.go

    	}
    	// 3.10.1 Check that old password no longer works.
    	err = client.MakeBucket(ctx, getRandomBucketName(), minio.MakeBucketOptions{})
    	if err == nil {
    		c.Fatalf("user was unexpectedly able to create bucket with bad password!")
    	}
    	// 3.10.2 Check that new password works.
    	client = s.getUserClient(c, accessKey, newSecretKey, "")
    	err = client.MakeBucket(ctx, getRandomBucketName(), minio.MakeBucketOptions{})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.4K bytes
    - Viewed (0)
  5. cmd/erasure-object_test.go

    	objLayer, disks, err = prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// cleaning up of temporary test directories
    	defer objLayer.Shutdown(t.Context())
    	defer removeRoots(disks)
    
    	err = objLayer.MakeBucket(ctx, "bucket1", MakeBucketOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	res, err := objLayer.NewMultipartUpload(ctx, "bucket1", "mpartObj1", opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  6. cmd/object-api-multipart_test.go

    	}
    	if errMsg != err.Error() {
    		t.Errorf("%s, Expected to fail with Error \"%s\", but instead found \"%s\".", instanceType, errMsg, err.Error())
    	}
    
    	// Create bucket before initiating NewMultipartUpload.
    	err = obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{})
    	if err != nil {
    		// failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  7. cmd/sts-handlers_test.go

    	}
    }
    
    func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    	defer cancel()
    
    	bucket := "dillon-bucket"
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket create error: %v", err)
    	}
    
    	// Create policy
    	policy := "mypolicy-username"
    	policyBytes := []byte(`{
     "Version": "2012-10-17",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  8. cmd/erasure-healing_test.go

    		t.Fatalf("Unable to initialize server config. %s", err)
    	}
    
    	defer removeRoots(fsDirs)
    
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	// Create "bucket"
    	err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	bucket := "bucket"
    	object := "object"
    
    	data := make([]byte, 1*humanize.MiByte)
    	length := int64(len(data))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  9. cmd/api-datatypes.go

    	ReplicateDecisionStr string `xml:"-"`
    }
    
    // createBucketLocationConfiguration container for bucket configuration request from client.
    // Used for parsing the location from the request body for Makebucket.
    type createBucketLocationConfiguration struct {
    	XMLName  xml.Name `xml:"CreateBucketConfiguration" json:"-"`
    	Location string   `xml:"LocationConstraint"`
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 3K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users-race_test.go

    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestDeleteUserRace(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 90*time.Second)
    	defer cancel()
    
    	bucket := getRandomBucketName()
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket creat error: %v", err)
    	}
    
    	// Create a policy policy
    	policy := "mypolicy"
    	policyBytes := fmt.Appendf(nil, `{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4K bytes
    - Viewed (0)
Back to top