- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 162 for newReader (0.07 sec)
-
cmd/admin-handlers-config-kv.go
if err != nil { return } result.Dynamic, err = result.Cfg.ReadConfig(bytes.NewReader(kvBytes)) if err != nil { return } result.SubSys, _, _, err = config.GetSubSys(string(kvBytes)) if err != nil { return } tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes)) if err != nil { return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.7K bytes - Viewed (1) -
cmd/streaming-v4-unsigned.go
for _, key := range trailers { req.Trailer.Add(key, "") } } else { req.Trailer = nil } return &s3UnsignedChunkedReader{ trailers: req.Trailer, reader: bufio.NewReader(req.Body), buffer: make([]byte, 64*1024), }, ErrNone } // Represents the overall state that is required for decoding a // AWS Signature V4 chunked reader. type s3UnsignedChunkedReader struct {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Apr 03 14:55:52 UTC 2025 - 6.3K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen_test.go
} vn := DailyAllTierStats{} 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 BenchmarkEncodeDailyAllTierStats(b *testing.B) { v := DailyAllTierStats{} var buf bytes.Buffer msgp.Encode(&buf, &v)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/bucket-metadata.go
} if len(b.LifecycleConfigXML) != 0 { b.lifecycleConfig, err = lifecycle.ParseLifecycleConfig(bytes.NewReader(b.LifecycleConfigXML)) if err != nil { return err } } else { b.lifecycleConfig = nil } if len(b.EncryptionConfigXML) != 0 { b.sseConfig, err = bucketsse.ParseBucketSSEConfig(bytes.NewReader(b.EncryptionConfigXML)) if err != nil { return err } } else { b.sseConfig = nil
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 16 14:27:42 UTC 2025 - 18.1K bytes - Viewed (0) -
cmd/tier_gen_test.go
} vn := TierConfigMgr{} 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 BenchmarkEncodeTierConfigMgr(b *testing.B) { v := TierConfigMgr{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 2.3K bytes - Viewed (0) -
cmd/mrf_gen_test.go
} vn := PartialOperation{} 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 BenchmarkEncodePartialOperation(b *testing.B) { v := PartialOperation{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 2.4K bytes - Viewed (0) -
cmd/metacache-set_gen_test.go
} vn := listPathOptions{} 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 BenchmarkEncodelistPathOptions(b *testing.B) { v := listPathOptions{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 2.4K bytes - Viewed (0) -
cmd/metacache-walk_gen_test.go
} vn := WalkDirOptions{} 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 BenchmarkEncodeWalkDirOptions(b *testing.B) { v := WalkDirOptions{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2.3K bytes - Viewed (0) -
cmd/site-replication-utils_gen_test.go
} vn := SiteResyncStatus{} 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 BenchmarkEncodeSiteResyncStatus(b *testing.B) { v := SiteResyncStatus{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Nov 14 15:16:40 UTC 2022 - 2.4K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
int64(len(testCase.objects)), bytes.NewReader(testCase.objects), testCase.accessKey, testCase.secretKey, nil) } else { req, err = newTestRequest(http.MethodPost, getDeleteMultipleObjectsURL("", testCase.bucket), int64(len(testCase.objects)), bytes.NewReader(testCase.objects)) } if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 39.8K bytes - Viewed (0)