Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for mustGetPutObjReader (0.07 sec)

  1. 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),
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 76.1K bytes
    - Viewed (0)
  2. cmd/bucket-handlers_test.go

    func testRemoveBucketHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    	credentials auth.Credentials, t *testing.T,
    ) {
    	_, err := obj.PutObject(GlobalContext, bucketName, "test-object", mustGetPutObjReader(t, bytes.NewReader([]byte{}), int64(0), "", "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"), ObjectOptions{})
    	// if object upload fails stop the test.
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 39.8K bytes
    - Viewed (0)
  3. cmd/object-api-multipart_test.go

    	}
    
    	// Validate all the test cases.
    	for i, testCase := range testCases {
    		actualInfo, actualErr := obj.PutObjectPart(context.Background(), testCase.bucketName, testCase.objName, testCase.uploadID, testCase.PartID, mustGetPutObjReader(t, bytes.NewBufferString(testCase.inputReaderData), testCase.inputDataSize, testCase.inputMd5, testCase.inputSHA256), opts)
    		// All are test cases above are expected to fail.
    		if actualErr != nil && testCase.shouldPass {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  4. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    		17 + // ";chunk-signature="
    		64 + // e.g. "f2ca1bb6c7e907d06dafe4687e579fce76b37e4e93b7605022da52e6ccc26fd2"
    		2 + // CRLF
    		chunkDataSize +
    		2 // CRLF
    }
    
    func mustGetPutObjReader(t TestErrHandler, data io.Reader, size int64, md5hex, sha256hex string) *PutObjReader {
    	hr, err := hash.NewReader(context.Background(), data, size, md5hex, sha256hex, size)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top