Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 162 for newLoader (0.09 sec)

  1. cmd/config-encrypted_test.go

    	}{
    		{edata1, cred1, true},
    		{edata2, cred2, true},
    		{data, cred1, false},
    	}
    
    	for _, test := range tests {
    		t.Run("", func(t *testing.T) {
    			ddata, err := madmin.DecryptData(test.cred.String(), bytes.NewReader(test.edata))
    			if err != nil && test.success {
    				t.Errorf("Expected success, saw failure %v", err)
    			}
    			if err == nil && !test.success {
    				t.Error("Expected failure, saw success")
    			}
    			if test.success {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  2. cmd/object-handlers-common_test.go

    			expectedCode:    304,
    		},
    	}
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			recorder := httptest.NewRecorder()
    			request := httptest.NewRequest(http.MethodHead, "/bucket/a", bytes.NewReader([]byte{}))
    			request.Header.Set(xhttp.IfNoneMatch, tc.ifNoneMatch)
    			request.Header.Set(xhttp.IfModifiedSince, tc.ifModifiedSince)
    			request.Header.Set(xhttp.IfMatch, tc.ifMatch)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  3. docs/debugging/inspect/export.go

    		case 0:
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(b))
    			if e != nil {
    				return nil, e
    			}
    		case 1, 2:
    			v, b, e := msgp.ReadBytesZC(b)
    			if e != nil {
    				return nil, e
    			}
    			if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil {
    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(v))
    			if e != nil {
    				return nil, e
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:38:44 UTC 2025
    - 9.1K bytes
    - Viewed (1)
  4. cmd/storage-datatypes_test.go

    func BenchmarkDecodeVolInfoMsgp(b *testing.B) {
    	v := VolInfo{
    		Name:    "uuid",
    		Created: time.Now(),
    	}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    
    	for b.Loop() {
    		err := v.DecodeMsg(dc)
    		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
    - 9.1K bytes
    - Viewed (0)
  5. cmd/benchmark-utils_test.go

    	for i := 0; b.Loop(); i++ {
    		// insert the object.
    		objInfo, err := obj.PutObject(b.Context(), 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CharSinkTest.java

          assertThrows(IOException.class, () -> failSource.copyTo(okSink));
          // ensure writer was closed IF it was opened (depends on implementation whether or not it's
          // opened at all if source.newReader() throws).
          assertTrue(
              "stream not closed when copying from source with option: " + option,
              !okSink.wasStreamOpened() || okSink.wasStreamClosed());
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. cmd/object-api-utils_test.go

    	rec := httptest.NewRecorder()
    	// construct HTTP request for Get Object end point.
    	req, err := newTestSignedRequestV4(http.MethodPut, getPutObjectURL("", bucketName, objectName),
    		int64(5), bytes.NewReader([]byte("hello")), credentials.AccessKey, credentials.SecretKey, map[string]string{})
    	if err != nil {
    		t.Fatalf("failed to create HTTP request for Put Object: <ERROR> %v", err)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  8. cmd/object-handlers_test.go

    				int64(testCase.dataLen), testCase.chunkSize, bytes.NewReader(testCase.data),
    				testCase.accessKey, testCase.secretKey)
    		case testCase.contentEncoding == "":
    			req, err = newTestStreamingSignedRequest(http.MethodPut,
    				getPutObjectURL("", testCase.bucketName, testCase.objectName),
    				int64(testCase.dataLen), testCase.chunkSize, bytes.NewReader(testCase.data),
    				testCase.accessKey, testCase.secretKey)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  9. cmd/bucket-encryption_test.go

    			</Rule>
    			</ServerSideEncryptionConfiguration>`,
    			expectedErr: nil,
    			shouldPass:  true,
    		},
    	}
    
    	for i, tc := range testCases {
    		_, err := validateBucketSSEConfig(bytes.NewReader([]byte(tc.inputXML)))
    		if tc.shouldPass && err != nil {
    			t.Fatalf("Test case %d: Expected to succeed but got %s", i+1, err)
    		}
    
    		if !tc.shouldPass {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 14 07:59:05 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  10. cmd/data-scanner_test.go

                           </LifecycleConfiguration>`
    	deleteAllLc, err := lifecycle.ParseLifecycleConfig(strings.NewReader(deleteAllILM))
    	if err != nil {
    		t.Fatalf("Failed to parse deleteAllILM test ILM policy %v", err)
    	}
    	delMarkerLc, err := lifecycle.ParseLifecycleConfig(strings.NewReader(delMarkerILM))
    	if err != nil {
    		t.Fatalf("Failed to parse delMarkerILM test ILM policy %v", err)
    	}
    	tests := []struct {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
Back to top