Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newBytesRSC (0.19 sec)

  1. internal/s3select/select_benchmark_test.go

    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			s3Select, err := NewS3Select(bytes.NewReader(requestXML))
    			if err != nil {
    				b.Fatal(err)
    			}
    
    			if err = s3Select.Open(newBytesRSC(csvData)); err != nil {
    				b.Fatal(err)
    			}
    
    			s3Select.Evaluate(&nullResponseWriter{})
    			s3Select.Close()
    		}
    	})
    }
    
    func benchmarkSelectAll(b *testing.B, count int) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  2. internal/s3select/select_test.go

    	"strings"
    	"testing"
    
    	"github.com/klauspost/cpuid/v2"
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/simdjson-go"
    )
    
    func newStringRSC(s string) io.ReadSeekCloser {
    	return newBytesRSC([]byte(s))
    }
    
    func newBytesRSC(b []byte) io.ReadSeekCloser {
    	r := bytes.NewReader(b)
    	segmentReader := func(offset int64) (io.ReadCloser, error) {
    		_, err := r.Seek(offset, io.SeekStart)
    		if err != nil {
    			return nil, err
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
Back to top