Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 208 for NewReader (0.19 seconds)

  1. src/bufio/example_test.go

    func ExampleWriter_ReadFrom() {
    	var buf bytes.Buffer
    	writer := bufio.NewWriter(&buf)
    
    	data := "Hello, world!\nThis is a ReadFrom example."
    	reader := strings.NewReader(data)
    
    	n, err := writer.ReadFrom(reader)
    	if err != nil {
    		fmt.Println("ReadFrom Error:", err)
    		return
    	}
    
    	if err = writer.Flush(); err != nil {
    		fmt.Println("Flush Error:", err)
    		return
    	}
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 01 21:52:12 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  2. cmd/erasure-object_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	// PutObjectPart should succeed even if part already exists. ref: https://github.com/minio/minio/issues/1930
    	_, err = objLayer.PutObjectPart(ctx, "bucket1", "mpartObj1", res.UploadID, 1, mustGetPutObjReader(t, bytes.NewReader(fiveMBBytes), 5*humanize.MiByte, md5Hex, ""), opts)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  3. 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()))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 73.9K bytes
    - Click Count (0)
  4. 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)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  5. doc/godebug.md

    ### Go 1.20
    
    Go 1.20 introduced support for rejecting insecure paths in tar and zip archives,
    controlled by the [`tarinsecurepath` setting](/pkg/archive/tar/#Reader.Next)
    and the [`zipinsecurepath` setting](/pkg/archive/zip/#NewReader).
    These default to `tarinsecurepath=1` and `zipinsecurepath=1`,
    preserving the behavior of earlier versions of Go.
    A future version of Go may change the defaults to
    `tarinsecurepath=0` and `zipinsecurepath=0`.
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 15:49:10 GMT 2026
    - 26K bytes
    - Click Count (0)
  6. cmd/xl-storage-format-v1_gen_test.go

    	}
    
    	vn := ChecksumInfo{}
    	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 BenchmarkEncodeChecksumInfo(b *testing.B) {
    	v := ChecksumInfo{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.2K bytes
    - Click Count (0)
  7. internal/config/policy/opa/config.go

    	CloseRespFn func(r io.ReadCloser) `json:"-"`
    }
    
    // Validate - validate opa configuration params.
    func (a *Args) Validate() error {
    	req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte("")))
    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	if a.AuthToken != "" {
    		req.Header.Set("Authorization", a.AuthToken)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool-rebalance_gen_test.go

    	}
    
    	vn := rebalanceInfo{}
    	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 BenchmarkEncoderebalanceInfo(b *testing.B) {
    	v := rebalanceInfo{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11K bytes
    - Click Count (0)
  9. internal/dsync/lock-args_gen_test.go

    	}
    
    	vn := LockArgs{}
    	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 BenchmarkEncodeLockArgs(b *testing.B) {
    	v := LockArgs{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  10. cmd/metacache_gen_test.go

    	}
    
    	vn := metacache{}
    	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 BenchmarkEncodemetacache(b *testing.B) {
    	v := metacache{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
Back to Top