- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for NewReader (0.25 sec)
-
cmd/untar.go
bf := bufio.NewReader(r) switch f := detect(bf); f { case formatGzip: gz, err := gzip.NewReader(bf) if err != nil { return err } defer gz.Close() r = gz case formatS2: r = s2.NewReader(bf) case formatZstd: // Limit to 16 MiB per stream. dec, err := zstd.NewReader(bf, zstd.WithDecoderMaxWindow(16<<20)) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
t.Fatal(err) } for _, file := range files { t.Run(file.Name(), func(t *testing.T) { f, err := os.Open(filepath.Join("testdata", file.Name())) if err != nil { t.Fatal(err) } r := NewReader(f, &ReaderArgs{}) var record sql.Record for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.5K 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) -
cmd/object-api-deleteobject_test.go
} for _, object := range testCase.objectToUploads { md5Bytes := md5.Sum([]byte(object.content)) oi, err := obj.PutObject(context.Background(), testCase.bucketName, object.name, mustGetPutObjReader(t, strings.NewReader(object.content), int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{}) t.Log(oi) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 3.9K bytes - Viewed (0) -
internal/config/identity/openid/provider/keycloak.go
values.Set("client_id", clientID) values.Set("client_secret", clientSecret) values.Set("grant_type", "client_credentials") req, err := http.NewRequest(http.MethodPost, k.oeConfig.TokenEndpoint, strings.NewReader(values.Encode())) if err != nil { return err } req.Header.Set("Content-Type", "application/x-www-form-urlencoded") resp, err := k.client.Do(req) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 4.6K bytes - Viewed (0) -
internal/disk/stat_linux.go
} return } func readStat(fileName string) (stats []uint64, err error) { file, err := os.Open(fileName) if err != nil { return nil, err } defer file.Close() s, err := bufio.NewReader(file).ReadString('\n') if err != nil && !errors.Is(err, io.EOF) { return nil, err } statLine := strings.TrimSpace(s) for _, token := range strings.Fields(statLine) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
if err != nil { return nil, err } defer file.Close() return parseMountFrom(file) } func parseMountFrom(file io.Reader) (mountInfos, error) { mounts := mountInfos{} scanner := bufio.NewReader(file) for { line, err := scanner.ReadString('\n') if err == io.EOF { break } fields := strings.Fields(line) if len(fields) != expectedNumFieldsPerLine { // ignore incorrect lines.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.7K bytes - Viewed (0) -
cmd/batch-expire_gen_test.go
} vn := BatchJobExpire{} 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 BenchmarkEncodeBatchJobExpire(b *testing.B) { v := BatchJobExpire{} 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: Sat Dec 02 10:51:33 GMT 2023 - 6.9K bytes - Viewed (0) -
cmd/last-minute_gen_test.go
} vn := AccElem{} 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 BenchmarkEncodeAccElem(b *testing.B) { v := AccElem{} 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: Tue Jul 05 21:45:49 GMT 2022 - 6.8K bytes - Viewed (0)