- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 86 for NewReader (0.16 sec)
-
cmd/config-common.go
return errConfigNotFound } return err } func saveConfigWithOpts(ctx context.Context, store objectIO, configFile string, data []byte, opts ObjectOptions) error { hashReader, err := hash.NewReader(ctx, bytes.NewReader(data), int64(len(data)), "", getSHA256Hash(data), int64(len(data))) if err != nil { return err } _, err = store.PutObject(ctx, minioMetaBucket, configFile, NewPutObjReader(hashReader), opts) return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 3.1K 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()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 2.4K bytes - Viewed (0) -
src/bytes/reader.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 3.9K bytes - Viewed (1) -
docs/sts/client-grants.go
} func getTokenExpiry() (*credentials.ClientGrantsToken, error) { data := url.Values{} data.Set("grant_type", "client_credentials") req, err := http.NewRequest(http.MethodPost, idpEndpoint, strings.NewReader(data.Encode())) if err != nil { return nil, err } req.Header.Set("Content-Type", "application/x-www-form-urlencoded") req.SetBasicAuth(clientID, clientSecret) t := &http.Transport{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 3.3K bytes - Viewed (0) -
internal/s3select/json/reader.go
for range r.valueCh { // Drain values so we don't leak a goroutine. // Since we have closed the input, it should fail rather quickly. } return err } // NewReader - creates new JSON reader using readCloser. func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader { readCloser = &syncReadCloser{rc: readCloser} d := jstream.NewDecoder(readCloser, 0).ObjectAsKVS() return &Reader{ args: args,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
internal/crypto/key.go
mac.Write([]byte(domain)) mac.Write([]byte(SealAlgorithm)) mac.Write([]byte(path.Join(bucket, object))) // use path.Join for canonical 'bucket/object' mac.Sum(sealingKey[:0]) if n, err := sio.Encrypt(&encryptedKey, bytes.NewReader(key[:]), sio.Config{Key: sealingKey[:], CipherSuites: fips.DARECiphers()}); n != 64 || err != nil { logger.CriticalIf(context.Background(), errors.New("Unable to generate sealed key")) } sealedKey := SealedKey{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:28:10 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/tier-journal_test.go
} var b bytes.Buffer for _, item := range readOldToNewCases { bs, err := item.je.MarshalMsg(nil) if err != nil { t.Fatal(err) } b.Write(bs) } mr := msgp.NewReader(&b) for i, item := range readOldToNewCases { var je jentry err := je.DecodeMsg(mr) if err != nil { t.Fatal(err) } if je != item.exp { t.Errorf("Case %d: Expected: %v Got: %v", i, item.exp, je)
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 3.2K 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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
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() b.ResetTimer() for i := 0; i < b.N; i++ { err := v.DecodeMsg(dc) if err != nil { b.Fatal(err) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 9.4K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
err = fmt.Errorf("unexpected root json type:%v", typ) r.err = &err return } } if in.Error == io.EOF { return } } } // NewReader - creates new JSON reader using readCloser. func NewReader(readCloser io.ReadCloser, args *json.ReaderArgs) *Reader { r := Reader{ args: args, readCloser: &safeCloser{r: io.Reader(readCloser)},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0)