Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 208 for newReader (0.12 sec)

  1. internal/store/queuestore.go

    		decodedBytes, err := s2.Decode(nil, raw)
    		if err != nil {
    			return nil, err
    		}
    		decoder = jsoniter.ConfigCompatibleWithStandardLibrary.NewDecoder(bytes.NewReader(decodedBytes))
    	} else {
    		decoder = jsoniter.ConfigCompatibleWithStandardLibrary.NewDecoder(bytes.NewReader(raw))
    	}
    
    	for decoder.More() {
    		var item I
    		if err := decoder.Decode(&item); err != nil {
    			return nil, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  2. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. src/bytes/reader.go

    		err = io.ErrShortWrite
    	}
    	return
    }
    
    // Reset resets the [Reader] to be reading from b.
    func (r *Reader) Reset(b []byte) { *r = Reader{b, 0, -1} }
    
    // NewReader returns a new [Reader] reading from b.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. src/archive/tar/example_test.go

    		if _, err := tw.Write([]byte(file.Body)); err != nil {
    			log.Fatal(err)
    		}
    	}
    	if err := tw.Close(); err != nil {
    		log.Fatal(err)
    	}
    
    	// Open and iterate through the files in the archive.
    	tr := tar.NewReader(&buf)
    	for {
    		hdr, err := tr.Next()
    		if err == io.EOF {
    			break // End of archive
    		}
    		if err != nil {
    			log.Fatal(err)
    		}
    		fmt.Printf("Contents of %s:\n", hdr.Name)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 16 16:54:08 UTC 2017
    - 1.4K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_test.go

    	f, err := os.Open("testdata/xl.meta-corrupt.gz")
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer f.Close()
    
    	gz, err := gzip.NewReader(bufio.NewReader(f))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	buf, err := io.ReadAll(gz)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	_, err = readXLMetaNoData(bytes.NewReader(buf), int64(len(buf)))
    	if err == nil {
    		t.Fatal("expected error but returned success")
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  6. 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)},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  7. cmd/object-handlers-common_test.go

    			expectedCode:    304,
    		},
    	}
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			recorder := httptest.NewRecorder()
    			request := httptest.NewRequest(http.MethodHead, "/bucket/a", bytes.NewReader([]byte{}))
    			request.Header.Set(xhttp.IfNoneMatch, tc.ifNoneMatch)
    			request.Header.Set(xhttp.IfModifiedSince, tc.ifModifiedSince)
    			request.Header.Set(xhttp.IfMatch, tc.ifMatch)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader_amd64_test.go

    	"github.com/minio/simdjson-go"
    )
    
    type tester interface {
    	Fatal(args ...interface{})
    }
    
    func loadCompressed(t tester, file string) (js []byte) {
    	dec, err := zstd.NewReader(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer dec.Close()
    	js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	js, err = dec.DecodeAll(js, nil)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  9. cmd/config-encrypted_test.go

    	}{
    		{edata1, cred1, true},
    		{edata2, cred2, true},
    		{data, cred1, false},
    	}
    
    	for _, test := range tests {
    		t.Run("", func(t *testing.T) {
    			ddata, err := madmin.DecryptData(test.cred.String(), bytes.NewReader(test.edata))
    			if err != nil && test.success {
    				t.Errorf("Expected success, saw failure %v", err)
    			}
    			if err == nil && !test.success {
    				t.Error("Expected failure, saw success")
    			}
    			if test.success {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  10. cmd/benchmark-utils_test.go

    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		// insert the object.
    		objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
    			mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{})
    		if err != nil {
    			b.Fatal(err)
    		}
    		if objInfo.ETag != md5hex {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 23 15:46:00 UTC 2022
    - 8.2K bytes
    - Viewed (0)
Back to top