- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 162 for newLoader (0.05 sec)
-
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) -
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) -
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) -
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) -
cmd/benchmark-utils_test.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.1K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)