- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 94 for NewReader (0.44 sec)
-
internal/etag/etag_test.go
}, } func TestReader(t *testing.T) { for i, test := range readerTests { reader := NewReader(context.Background(), strings.NewReader(test.Content), test.ETag, nil) if _, err := io.Copy(io.Discard, reader); err != nil { t.Fatalf("Test %d: read failed: %v", i, err) } if ETag := reader.ETag(); !Equal(ETag, test.ETag) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 12.6K bytes - Viewed (0) -
cmd/post-policy_test.go
t.Fatalf("Test %d: %s: Failed to create HTTP request for PostPolicyHandler: <ERROR> %v", i+1, instanceType, perr) } if testCase.malformedBody { // Change the request body. req.Body = io.NopCloser(bytes.NewReader([]byte("Hello,"))) } // Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(rec, req)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/sts-handlers.go
writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, errSessionPolicyTooLarge) return } if len(sessionPolicyStr) > 0 { sessionPolicy, err := policy.ParseConfig(bytes.NewReader([]byte(sessionPolicyStr))) if err != nil { writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, err) return } // Version in policy must not be empty if sessionPolicy.Version == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 21:31:13 GMT 2024 - 34.7K bytes - Viewed (2) -
src/bytes/example_test.go
// Output: // 'Gjnf oevyyvt naq gur fyvgul tbcure... } func ExampleReader_Len() { fmt.Println(bytes.NewReader([]byte("Hi!")).Len()) fmt.Println(bytes.NewReader([]byte("こんにちは!")).Len()) // Output: // 3 // 16 } func ExampleRepeat() { fmt.Printf("ba%s", bytes.Repeat([]byte("na"), 2)) // Output: banana }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:40 GMT 2024 - 15K bytes - Viewed (1) -
cmd/streaming-signature-v4.go
for _, key := range trailers { req.Trailer.Add(key, "") } } else { req.Trailer = nil } return &s3ChunkedReader{ trailers: req.Trailer, reader: bufio.NewReader(req.Body), cred: cred, seedSignature: seedSignature, seedDate: seedDate, region: region, chunkSHA256Writer: sha256.New(), buffer: make([]byte, 64*1024),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
internal/bucket/replication/replication_test.go
expectedValidationErr: nil, }, } for i, tc := range testCases { t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) { cfg, err := ParseConfig(bytes.NewReader([]byte(tc.inputConfig))) if err != nil && tc.expectedParsingErr != nil && err.Error() != tc.expectedParsingErr.Error() { t.Fatalf("%d: Expected '%v' during parsing but got '%v'", i+1, tc.expectedParsingErr, err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 32.5K bytes - Viewed (0) -
internal/event/config_test.go
t.Fatalf("test %v: data: expected: %v, got: %v", i+1, testCase.expectedResult, result) } } } func TestParseConfig(t *testing.T) { reader1 := strings.NewReader(` <NotificationConfiguration xmlns="http://s3.amazonaws.com/doc/2006-03-01/"> <QueueConfiguration> <Id>1</Id> <Filter></Filter> <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue>
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 29K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
rec := httptest.NewRecorder() // construct HTTP request req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName), int64(len(testCase.body)), bytes.NewReader(testCase.body), testCase.accessKey, testCase.secretKey, nil) if err != nil { t.Fatalf("Test %d: %s: Failed to create HTTP request for GetBucketLocationHandler: <ERROR> %v", i+1, instanceType, err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 13 20:52:33 GMT 2023 - 11.2K bytes - Viewed (0) -
cmd/config-current.go
logger.Fatal(err, "Unable to generate root secret key using KMS") } accessKey, err := auth.GenerateAccessKey(20, bytes.NewReader(aKey)) if err != nil { logger.Fatal(err, "Unable to generate root access key") } secretKey, err := auth.GenerateSecretKey(32, bytes.NewReader(sKey)) if err != nil { logger.Fatal(err, "Unable to generate root secret key") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
src/archive/tar/tar_test.go
} if _, err := tw.Write(data); err != nil { t.Fatalf("tw.Write: %v", err) } if err := tw.Close(); err != nil { t.Fatalf("tw.Close: %v", err) } // Read it back. tr := NewReader(&b) rHdr, err := tr.Next() if err != nil { t.Fatalf("tr.Next: %v", err) } if !reflect.DeepEqual(rHdr, hdr) { t.Errorf("Header mismatch.\n got %+v\nwant %+v", rHdr, hdr) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0)