- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 121 for NewReader (0.2 sec)
-
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) -
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) -
internal/rest/client.go
if body != nil { switch v := body.(type) { case *bytes.Buffer: req.ContentLength = int64(v.Len()) buf := v.Bytes() req.GetBody = func() (io.ReadCloser, error) { r := bytes.NewReader(buf) return io.NopCloser(r), nil } case *bytes.Reader: req.ContentLength = int64(v.Len()) snapshot := *v req.GetBody = func() (io.ReadCloser, error) { r := snapshot
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/bucket-replication.go
) var objectSize int64 for _, partInfo := range objInfo.Parts { if crypto.SSEC.IsEncrypted(objInfo.UserDefined) { hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize) } else { hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.ActualSize), partInfo.ActualSize, "", "", partInfo.ActualSize) } if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/object-api-utils.go
var dopts []s2.ReaderOption if off > 0 || decOff > 0 { // We are not starting at the beginning, so ignore stream identifiers. dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier()) } s2Reader := s2.NewReader(inputReader, dopts...) // Apply the skipLen and limit on the decompressed stream. if decOff > 0 { if err = s2Reader.Skip(decOff); err != nil { // Call the cleanup funcs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/bucket-stats_gen_test.go
} vn := BucketReplicationStat{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodeBucketReplicationStat(b *testing.B) { v := BucketReplicationStat{} var buf bytes.Buffer msgp.Encode(&buf, &v)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 30 08:00:59 GMT 2023 - 20.5K bytes - Viewed (0) -
cmd/batch-expire.go
xioutil.SafeClose(saverQuitCh) // Notify expire jobs final status to the configured endpoint buf, _ := json.Marshal(ri) if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil { batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err)) } return nil } //msgp:ignore batchExpireJobError type batchExpireJobError struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/site-replication.go
// do some validation. newReplCfgBytes, err := xml.Marshal(replicationConfig) if err != nil { return err } newReplicationConfig, err := sreplication.ParseConfig(bytes.NewReader(newReplCfgBytes)) if err != nil { return err } sameTarget, apiErr := validateReplicationDestination(ctx, bucket, newReplicationConfig, true) if apiErr != noError {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/storage-datatypes_gen_test.go
} vn := BaseOptions{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodeBaseOptions(b *testing.B) { v := BaseOptions{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 60.4K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
var expectedPolicy *policy.BucketPolicy expectedPolicy, err = policy.ParseBucketPolicyConfig(strings.NewReader(expectedBucketPolicyStr), testCase.bucketName) if err != nil { t.Fatalf("unexpected error. %v", err) } var gotPolicy *policy.BucketPolicy gotPolicy, err = policy.ParseBucketPolicyConfig(bytes.NewReader(bucketPolicyReadBuf), testCase.bucketName) if err != nil { t.Fatalf("unexpected error. %v", err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 32.7K bytes - Viewed (0)