Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for mustGetPutObjReader (0.31 sec)

  1. cmd/erasure-object_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	// PutObjectPart should succeed even if part already exists. ref: https://github.com/minio/minio/issues/1930
    	_, err = objLayer.PutObjectPart(ctx, "bucket1", "mpartObj1", res.UploadID, 1, mustGetPutObjReader(t, bytes.NewReader(fiveMBBytes), 5*humanize.MiByte, md5Hex, ""), opts)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  2. cmd/object_api_suite_test.go

    	{
    		_, err = obj.PutObject(context.Background(), "bucket", "newPrefix", mustGetPutObjReader(t, bytes.NewBufferString(uploadContent), int64(len(uploadContent)), "", ""), opts)
    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    		_, err = obj.PutObject(context.Background(), "bucket", "newPrefix2", mustGetPutObjReader(t, bytes.NewBufferString(uploadContent), int64(len(uploadContent)), "", ""), opts)
    		if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  3. cmd/benchmark-utils_test.go

    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		// insert the object.
    		objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
    			mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{})
    		if err != nil {
    			b.Fatal(err)
    		}
    		if objInfo.ETag != md5hex {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 8.2K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	oi1, err := obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), length, "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    	// 2nd version.
    	_, _ = rand.Read(data)
    	oi2, err := obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), length, "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  5. cmd/object-api-putobject_test.go

    			inputMeta:     map[string]string{"etag": "e2fc714c4727ee9395f324cd2e7f331f", "x-amz-checksum-crc32": "abcd"},
    			inputDataSize: int64(len("abcd")),
    		},
    	}
    	for i, testCase := range testCases {
    		in := mustGetPutObjReader(t, bytes.NewReader(testCase.inputData), testCase.inputDataSize, testCase.inputMeta["etag"], testCase.inputSHA256)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  6. cmd/object-api-getobjectinfo_test.go

    	if err != nil {
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	// Put an empty directory
    	_, err = obj.PutObject(context.Background(), "test-getobjectinfo", "Asia/empty-dir/", mustGetPutObjReader(t, bytes.NewBufferString(""), int64(len("")), "", ""), opts)
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 5.6K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    		test := test
    		t.Run(fmt.Sprintf("case-%d", i), func(t *testing.T) {
    			_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), ObjectOptions{})
    			if err != nil {
    				t.Fatalf("Failed to putObject %v", err)
    			}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  8. cmd/object-api-deleteobject_test.go

    		}
    
    		for _, object := range testCase.objectToUploads {
    			md5Bytes := md5.Sum([]byte(object.content))
    			oi, err := obj.PutObject(context.Background(), testCase.bucketName, object.name, mustGetPutObjReader(t, strings.NewReader(object.content),
    				int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{})
    			t.Log(oi)
    			if err != nil {
    				t.Fatalf("%s : %s", instanceType, err.Error())
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    	}
    	for _, object := range testObjects {
    		md5Bytes := md5.Sum([]byte(object.content))
    		_, err = obj.PutObject(context.Background(), object.parentBucket, object.name, mustGetPutObjReader(t, bytes.NewBufferString(object.content),
    			int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{
    			Versioned:   globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/object-handlers_test.go

    	}
    	// iterate through the above set of inputs and upload the object.
    	for i, input := range putObjectInputs {
    		// uploading the object.
    		_, err := obj.PutObject(context.Background(), input.bucketName, input.objectName, mustGetPutObjReader(t, bytes.NewReader(input.textData), input.contentLength, input.metaData[""], ""), ObjectOptions{UserDefined: input.metaData})
    		// if object upload fails stop the test.
    		if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top